Does DaskTaskRunner support designated workers? Sp...
# prefect-community
u
Does DaskTaskRunner support designated workers? Specify in the dask as follows:
Copy code
future = client.submit(func, *args, workers=['Alice'],
                       allow_other_workers=True)
1
z
Yeah I believe if you use the Dask config context manager
u
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🙂.