Nathan Low
04/26/2023, 4:45 PMZanie
Zanie
foo.submit(1)
foo.map([2, 3])
?Nathan Low
04/26/2023, 5:59 PMZanie
Nathan Low
04/26/2023, 6:17 PMNathan Low
04/26/2023, 6:19 PMcta_load_list : PrefectFuture = get_security_master_staging_cta_load_list.submit()
cta_load_results = run_stored_procedure.map(
sql_util=unmapped(staging_sql_util), procedure_name=cta_load_list
)
security_master_side_load_list: PrefectFuture = (
get_security_master_staging_dw_side_load_list.submit()
side_load_results = run_stored_procedure.map(
sql_util=unmapped(dw_sql_util), procedure_name=security_master_side_load_list
)
Nathan Low
04/26/2023, 6:19 PMZanie
Nathan Low
04/26/2023, 6:47 PMNathan Low
04/26/2023, 6:48 PMZanie
Zanie
for i in items:
task.submit(i)
# same as task.map(items)
Zanie
Zanie
items
is a future we need to resolve the future to data (wait for it to complete) first so we can make those submissionsNathan Low
04/26/2023, 7:02 PM