dask_kube_utils

catlas.dask_kube_utils.get_namespace()

Return the Kubernetes namespace this code is run in.

Returns

the Kubernetes namespace this code is running in.

Return type

str

catlas.dask_kube_utils.kube_cluster_new_worker(cluster, config_path)

Generate a new kubernetes worker.

Parameters

• cluster (dask.distributed.client.Client) – a dask cluster to run code on.

• config_path (str) – a file path containing a config yml file defining the specifications of the new worker