python - Dask - how to assign task to the specific CPU

Question

I'm using Dask to process research batches, which are quite heavy (from few minutes to few hours). There's no communication between the tasks and they produce only side results. I'm using a machine which already virtualizes resources beneath it (~ 30 CPUs), so I'm just running LocalCluster. Is there any way to assign a specific CPU to a task? In docs there're only examples with gpu and memory.

I've tried to assign CPU in a similar way, but the tasks won't even start to process.

client.submit(process, d, resources={'CPU': 1}) for d in data]

Answer 1

I suspect this is best achieved by limiting the number of workers (cluster.scale(3)) and setting their process niceness

CPU time-sharing is really managed by the operating system