Is there an updated example of using dask from wit...
# ask-community
i
Is there an updated example of using dask from within a Prefect flow? I.e. a dask that calls
dask.compute()
using a Dask Executor? I'm trying to compare my upgraded (0.13.x to latest) flow code with a working example and right now my
compute
calls hang.
k
This is still the example that works for working with Dask DataFrames
i
Will
with worker_client():
set the Dask "current" or "global" clients?
k
Current, but I’m not sure what the different is? Wouldn’t you only have one Dask client?
i
Dask's Client.current checks two places
If it sets current that's what I want 🙂
Thanks
k
The docstring is unclear to me then if current or global but I assume current because it says client for the thread