Tim Enders
with 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()
task.set_dependencies()
Kevin Kho
task.set_dependencies
run_or_bail
apply_map
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.