Cab Maddux
04/14/2020, 7:08 PMLuke Orland
04/14/2020, 7:31 PMwith Flow(
"flow name",
environment=prefect.environments.RemoteEnvironment(
executor="prefect.engine.executors.DaskExecutor",
executor_kwargs={'n_workers': 4},
),
) as flow:
Cab Maddux
04/14/2020, 7:39 PMChris White
04/14/2020, 11:58 PMCab Maddux
04/15/2020, 1:16 AM