Tim Enders
10/20/2021, 1:39 PMwith Flow(
"AWS CUR import",
result=GCSResult(bucket="platformsh-vendor-prefect"),
state_handlers=[flow_failure],
) as flow:
# save_file = prefect.Parameter("Download Files", default=False)
num_periods = prefect.Parameter("num_periods", default=4)
periods = generate_periods(num_periods)
apply_map(run_or_bail, periods)
clear_files()
Tim Enders
10/20/2021, 1:43 PMtask.set_dependencies()
but I can't figure out what the upstream task should be in this context. The flow visualization doesn't look right each timeKevin Kho
task.set_dependencies
might have to go inside the tasks in run_or_bail
because apply_map
is a function that calls another function to add those tasks.Tim Enders
10/20/2021, 2:16 PM