Joshua Greenhalgh07/29/2022, 1:04 PM
? 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)
task but was thinking maybe something existed already?
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!
for flow_run in flow_runs: res = wait_for_flow_run(flow_run)
James Sopkin07/29/2022, 1:50 PM
with Flow('backfill_boot', executor=LocalDaskExecutor()) as backfill_boot:
Joshua Greenhalgh07/29/2022, 3:17 PM
James Sopkin07/29/2022, 3:37 PM