https://prefect.io logo
Title
c

Chohang Ng

06/03/2021, 1:56 AM
flow_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')