Joshua Greenhalgh
07/29/2022, 1:04 PMcreate_flow_run
?
Want to do something like;with Flow('backfill_boot') as backfill_boot:
flow_runs = []
for param in params:
flow_run = create_flow_run(
flow_name='flow_name',
project_name='production',parameters=param
)
flow_runs.append(flow_run)
wait_for(flow_runs)
wait_for_flow_run
task but was thinking maybe something existed already?for flow_run in flow_runs:
res = wait_for_flow_run(flow_run)
But each call to wait_for_flow_run blocks - would be nice to be able to stream the logs interleaved for all the flow_runs I am waiting for!James Sopkin
07/29/2022, 1:50 PMwith Flow('backfill_boot', executor=LocalDaskExecutor()) as backfill_boot:
Joshua Greenhalgh
07/29/2022, 3:17 PMJames Sopkin
07/29/2022, 3:37 PM