Harry Baker
07/28/2021, 8:25 PMKevin Kho
Harry Baker
07/28/2021, 8:47 PMKevin Kho
Zanie
Harry Baker
07/28/2021, 10:17 PMKevin Kho
create_flow_run
and wait_for_flow_run
. create_flow_run
returns the UUID, that you can pass into wait_for_flow_run
as the next task.Harry Baker
08/02/2021, 10:32 PMwith Flow('reporting_driver') as flow:
rd_id = create_flow_run(flow_name='refresh_data', project_name="tester")
rd_wait = wait_for_flow_run(rd_id, stream_logs=True)
qe_id = create_flow_run(flow_name='query_export', project_name="tester")
qe_wait = wait_for_flow_run(qe_id, stream_logs=True)
qe_id.set_upstream(rd_wait)
would this achieve what i'm looking for? I want refresh_data to run, passing its logs to the parent flow, and once its finished then query_export will do likewiseHarry Baker
08/02/2021, 10:44 PMHarry Baker
08/02/2021, 10:46 PMHarry Baker
08/02/2021, 10:57 PMHarry Baker
08/02/2021, 11:14 PMKevin Kho
Yueh-Han
08/03/2021, 8:12 AM