Hi, I've been trying to build a local Dask cluster...
# prefect-community
m
Hi, I've been trying to build a local Dask cluster to run my flows. Everything worked fine when I ran the flows locally:
Copy code
executor = DaskExecutor(address="<tcp://xxx>")
flow.run(executor = executor)
But when I registered the flows to run it in Prefect UI, they stopped running on my local Dask cluster. Neither scheduler or workers showed any reactions in terminal or in Bokeh. I wonder why this is happening?
e
Just to verify, are the following set up: 1. A running local agent 2. You triggered a flow run on the prefect UI after registering the flow 3. Is your flow registered with the correct environment? I believe it should be a
RemoteEnvironment
, that uses a
DaskExecutor
with
executor_kwargs
specifying the address (
RemoteEnvironment(executor=DaskExecutor, executor_kwargs={"address": "<tcp://xxx>"})
) You can check your flow storage end execution environment on the flow page of your UI.
upvote 1
m
I added a LocalEnvironment and it worked. Thank you!! @emre
e
Glad to help! Also, I just realized that
RemoteEnvironment
has been deprecated, and LocalEnvironment should be used. Sorry for misinforming 😢
m
It’s okay, thanks a lot XD