Anna Geller
08/30/2022, 4:26 PMresults
and state_handler
in 2.0?
with Flow(
"Subscriptions API Import",
result=GCSResult(bucket="platformsh-vendor-prefect"),
# executor=LocalExecutor(),
executor=LocalDaskExecutor(scheduler="threads", num_workers=5),
state_handlers=[flow_failure],
Tim Enders
08/30/2022, 4:26 PMAnna Geller
08/30/2022, 4:27 PMTim Enders
08/30/2022, 4:29 PMAnna Geller
08/30/2022, 4:34 PMTim Enders
08/30/2022, 4:39 PMLeon Kozlowski
09/06/2022, 8:12 PMAnna Geller
09/06/2022, 8:52 PM