Skip to content

Instantly share code, notes, and snippets.

@lauralorenz

lauralorenz/dask_flow_4.py

Created June 26, 2020 18:53
Show Gist options
  • Save lauralorenz/7cc01c8d674a64643b5a1fd7d59c25ce to your computer and use it in GitHub Desktop.
Save lauralorenz/7cc01c8d674a64643b5a1fd7d59c25ce to your computer and use it in GitHub Desktop.
Download ZIP
A flow using the DaskKubernetesEnvironment
Raw
dask_flow_4.py
from dask_flow import flow
from prefect.environments.storage import Docker
from prefect.environments import DaskKubernetesEnvironment
flow.storage = Docker(registry_url="gcr.io/execution-layer-demo/flows")
flow.environment = DaskKubernetesEnvironment()
flow.register('execution-layer-demo')
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment