Skip to content

Conversation

@jacobtomlinson
Copy link
Member

Allow users to set a custom worker command in dask_kubernetes.experimental.KubeCluster.

cluster = KubeCluster(name="customworkercommand",
                      worker_command=["python", "-m", "distributed.cli.dask_worker"])

Closes #537

@jacobtomlinson
Copy link
Member Author

jacobtomlinson commented Jul 29, 2022

Test failures are known problem, see #540

@jacobtomlinson jacobtomlinson merged commit 4b26481 into dask:main Jul 29, 2022
@jacobtomlinson jacobtomlinson deleted the custom-worker branch July 29, 2022 10:58
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Allow users to set the worker command in experimental.KubeCluster

1 participant