Michelle Wu
11/17/2020, 7:59 AMexecutor = 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?emre
11/17/2020, 10:54 AMRemoteEnvironment
, 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.Michelle Wu
11/18/2020, 2:11 AMemre
11/18/2020, 7:15 AMRemoteEnvironment
has been deprecated, and LocalEnvironment should be used. Sorry for misinforming 😢Michelle Wu
11/18/2020, 8:44 AM