Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.

Prefect Community

Hey, could someone point, how to get the number of threads and cores Dask worker has within Prefect task? I'm not spawning them from prefect but using the existing workers

Sorry, are you asking how many threads/cores an individual dask worker has? Or how many threads/cores your whole cluster has?

Prefect tasks themselves take a single thread per active task in a worker.

yes, the single dask worker that is currently executing the prefect task. There are multiple workers running on different hardware so I want to access this information.

For an accurate number (and assuming you're using a `DaskExecutor` ) you could do:

```from distributed import get_worker
get_worker().nthreads```

That gives the number of threads the worker has running. To access the actual number of cores available on the machine (which might be different), you can use `os.cpu_count`

thanks. `get_worker` might be just what I need