calm-soccer-24586
12/18/2024, 12:17 PMdependencies = get_workflow_dependencies()
wf_t = ImperativeWorkflow(name="root-workflow") # , failure_policy=failure_policy
node_dic = {}
for parent, child in dependencies:
if parent!=child:
if parent not in node_dic:
parent_module = importlib.import_module(f'workflows.{parent}')
parent_wf=getattr(parent_module, 'wf_test')
parent_launch_plan = LaunchPlan.get_or_create(
parent_wf, parent
)
node_dic[parent] = wf_t.add_launch_plan(parent_launch_plan)
if child not in node_dic:
child_module = importlib.import_module(f'workflows.{child}')
child_wf=getattr(child_module, 'wf_test')
parent_launch_plan = LaunchPlan.get_or_create(
child_wf, child
)
node_dic[child] = wf_t.add_launch_plan(parent_launch_plan)
# child_node = child_node.with_overrides(
# name=f"b-{child}"
# )
node_dic[parent].runs_before(node_dic[child])
high-accountant-32689
12/18/2024, 10:19 PMcalm-soccer-24586
12/18/2024, 10:40 PMcalm-soccer-24586
12/27/2024, 12:23 PMaverage-finland-92144
01/10/2025, 1:36 PM