restrict task to specific workers

[zhaojun060708]

In the latest release, how to restrict task to specific workers?

I have noticed dask have remove restrictions param from client.get, and the newly added workers param seems can not do the same thing.

Many thanks.

[fjetter]

You can provide worker addresses to Client.submit (kwarg worker) to constrain tasks to the provided workers

[zhaojun060708]

You can provide worker addresses to Client.submit (kwarg worker) to constrain tasks to the provided workers

It contains two tasks and two workers. I want tasks running on different worker. How could I achieve this?

[fjetter]

The typical way to schedule two tasks on two different workers is

fut1 = client.submit(func1, *args1, workers=["<worker_address1>"])
fut2 = client.submit(func2, *args2, workers=["<worker_address2>"])

I recommend moving this conversation to https://dask.discourse.group/ where you should receive a faster response for questions like this since the community is a more active over there. The github issue tracker is mostly used for bug reporting and development.