Michael Warnock
07/17/2021, 4:21 PMKevin Kho
Kevin Kho
import coiled
executor = DaskExecutor(
cluster_class=coiled.Cluster,
cluster_kwargs={
"software": "jrbourbeau/prefect",
"shutdown_on_close": False,
"name": "prefect-executor",
},
)
flow.run(
executor=executor,
)
and this will spin up a Dask cluster hosted by coiled upon flow run. More info here .Michael Warnock
07/17/2021, 4:30 PM