Does DaskTaskRunner support designated workers? Specify in the dask as follows:

future = client.submit(func, *args, workers=['Alice'],
                       allow_other_workers=True)

Yeah I believe if you use the Dask config context manager

Thank you very much for your reply. I mean, is there any parameter in DaskTaskRunner that controls which worker the current flow is running on? @flow( _task_runner=DaskTaskRunner(_ _cluster_kwargs={“n_workers”: 1, “workers”: [“Alice”]}_ ) ) _def my_flow():_ pass The reason for this is that different flow streams let the specified worker handle🙂.