https://prefect.io logo
Title
u

张强

09/26/2022, 3:41 AM
Does DaskTaskRunner support designated workers? Specify in the dask as follows:
future = client.submit(func, *args, workers=['Alice'],
                       allow_other_workers=True)
1
z

Zanie

09/26/2022, 2:47 PM
Yeah I believe if you use the Dask config context manager
u

张强

09/27/2022, 2:52 AM
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🙂.