Nathan Low
04/26/2023, 4:45 PMZanie
04/26/2023, 5:05 PMfoo.submit(1)
foo.map([2, 3])
?Nathan Low
04/26/2023, 5:59 PMZanie
04/26/2023, 6:16 PMNathan Low
04/26/2023, 6:17 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
)
Zanie
04/26/2023, 6:24 PMNathan Low
04/26/2023, 6:47 PMZanie
04/26/2023, 6:49 PMfor i in items:
task.submit(i)
# same as task.map(items)
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