bral
08/17/2020, 10:36 PMKyle Moon-Wright
08/17/2020, 10:48 PMDaskExecutor
. To attach it to your flow you'd like to register, you can attach the DaskExecutor
to a LocalEnvironment
for your flow like this:
from prefect import Flow
from prefect.environments import LocalEnvironment
from prefect.engine.executors import DaskExecutor
environment = LocalEnvironment(executor=DaskExecutor())
flow = Flow(
"Dask Executor Example",
environment=environment
)
flow.register(project_name="project_name")
bral
08/17/2020, 11:01 PM