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🙂.