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🙂.
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.