Henrik Väisänen
12/29/2020, 6:56 PMJim Crist-Harif
12/29/2020, 7:12 PMHenrik Väisänen
12/29/2020, 7:15 PMJim Crist-Harif
12/29/2020, 7:18 PMDaskExecutor
) you could do:
from distributed import get_worker
get_worker().nthreads
os.cpu_count
Henrik Väisänen
12/29/2020, 7:20 PMget_worker
might be just what I need