Migrated workflow from luigi (3p) to waluigi (custom) and fixed issues …

…#291,  #286, #293, #289

pyproject.toml

@@ -49,3 +49,5 @@ PyYAML = "5.4"
 better-boto = "0.43.0"
 deepmerge = "^0.3.0"
 yamale = "^3.0.8"
+networkx = "2.6.3"
+orjson = "^3.8.0"

servicecatalog_factory/cli.py

@@ -1,9 +1,11 @@
 #  Copyright 2021 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 #  SPDX-License-Identifier: Apache-2.0
 import os
+from datetime import datetime
 
 import yaml
 
+from servicecatalog_factory import environmental_variables
 from servicecatalog_factory.commands import bootstrap as bootstrap_commands
 from servicecatalog_factory.commands import configuration_management
 from servicecatalog_factory.commands import fix_issues as fix_issues_commands
@@ -13,6 +15,7 @@
 from servicecatalog_factory.commands import seed as seed_commands
 from servicecatalog_factory.commands import show_pipelines as show_pipelines_commands
 from servicecatalog_factory.commands import stacks
+from servicecatalog_factory.commands import task_reference as task_reference_commands
 from servicecatalog_factory import constants
 from servicecatalog_factory.commands import validate as validate_commands
 from servicecatalog_factory.commands import version as version_commands
@@ -48,9 +51,19 @@ def validate(p):
     validate_commands.validate(p)
 
 
+def setup_config():
+    if os.environ.get(environmental_variables.CACHE_INVALIDATOR):
+        click.echo(
+            f"Found existing CACHE_INVALIDATOR: {os.environ.get(environmental_variables.CACHE_INVALIDATOR)}"
+        )
+    else:
+        os.environ[environmental_variables.CACHE_INVALIDATOR] = str(datetime.now())
+
+
 @cli.command()
 @click.argument("p", type=click.Path(exists=True))
 def generate(p):
+    setup_config()
     generate_commands.generate(p)
 
 
@@ -683,5 +696,11 @@ def set_config_value(name, value):
     management_commands.set_config_value(name, value)
 
 
+@cli.command()
+@click.argument("p", type=click.Path())
+def generate_task_reference(p,):
+    task_reference_commands.generate_task_reference(p)
+
+
 if __name__ == "__main__":
     cli()