Skip to content

Instantly share code, notes, and snippets.

@lauralorenz

lauralorenz/dask_flow_1and2.py

Created June 26, 2020 18:27
Show Gist options
  • Save lauralorenz/dd905b5c0c64c51a4f6d412ec2d3cda5 to your computer and use it in GitHub Desktop.
Save lauralorenz/dd905b5c0c64c51a4f6d412ec2d3cda5 to your computer and use it in GitHub Desktop.
Download ZIP
Configuration on a flow using a distributed dask scheduler you've started
Raw
dask_flow_1and2.py
from dask_flow import flow
from prefect.engine.executors import DaskExecutor
executor = DaskExecutor(address="10.255.253.2:8786") # change this to yours
flow.run(executor=executor)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment