Carlo
02/26/2021, 8:13 PMflow_a = StartFlowRun(flow_name="A", project_name="examples", wait=True)
flow_b = StartFlowRun(flow_name="B", project_name="examples", wait=True)
flow_c = StartFlowRun(flow_name="C", project_name="examples", wait=True)
flow_d = StartFlowRun(flow_name="D", project_name="examples", wait=True)
with Flow("parent-flow", schedule=weekday_schedule) as flow:
b = flow_b(upstream_tasks=[flow_a])
c = flow_c(upstream_tasks=[flow_a])
d = flow_d(upstream_tasks=[b, c])
Carlo
02/26/2021, 10:23 PMflow_a = StartFlowRun(flow_name="A", project_name="examples", wait=True)
flow_b = StartFlowRun(flow_name="B", project_name="examples", wait=True)
flow_c = StartFlowRun(flow_name="C", project_name="examples", wait=True)
flow_d = StartFlowRun(flow_name="D", project_name="examples", wait=True)
with Flow("parent-flow", schedule=weekday_schedule) as flow:
param = Parameter('name', default='carlo')
parameters = {'name': param}
b = flow_b(upstream_tasks=[flow_a], parameters=parameters)
c = flow_c(upstream_tasks=[flow_a], parameters=parameters)
d = flow_d(upstream_tasks=[b, c], parameters=parameters)
nicholas