Vipul
09/18/2020, 11:33 AMwith Flow("MasterFlow") as master_flow:
cobdate = Parameter("cobdate")
staging_area = FlowRunTask(flow_name='staging_area',
parameters=dict(cobdate=cobdate),
project_name="SubFlow")
business_logic_layer = FlowRunTask(flow_name='business_logic_layer',
project_name="SubFlow")
data_mart = FlowRunTask(flow_name='data_mart',
project_name="SubFlow",
wait=True)
staging_area.set_downstream(data_mart)
business_logic_layer.set_downstream(data_mart)