Chohang Ng
06/03/2021, 1:56 AMflow_1_flow = StartFlowRun(flow_name='flow_1',project_name='tester',wait = True)
flow_2_flow = StartFlowRun(flow_name='flow_2',project_name='tester',wait = True)
flow_3_flow = StartFlowRun(flow_name='flow_3',project_name='tester',wait = True)
flow_4_flow = StartFlowRun(flow_name='flow_4',project_name='tester',wait = True)
flow_5_flow = StartFlowRun(flow_name='flow_5',project_name='tester',wait = True)
with Flow("main-flow", schedule=weekday_schedule,executor=LocalExecutor(),
run_config=LocalRun()) as flow:
flow_3 = flow_3_flow()
flow_1_flow().set_upstream(flow_2_flow())
step_2 = flow_4_flow(upstream_tasks = [flow_1_flow(),flow_3])
step_3 = flow_5_flow(upstream_tasks= [step_2])
flow.register(project_name='tester')