import sys
from distributed.deploy import Cluster
import dask_kubernetes
def main():
print(
Cluster()
) # Cluster(e174b1b2, '<Not Connected>', workers=0, threads=0, memory=0 B)
try:
dask_kubernetes.HelmCluster(
release_name="example-release", namespace="example-namespace"
)
except RuntimeError:
pass # I don't have helm installed
print(
Cluster()
) # Cluster(example-release.example-namespace, '<Not Connected>', workers=0, threads=0, memory=0 B)
return 0
if __name__ == "__main__":
sys.exit(main())
see also dask/distributed#5305 (comment)