dae.dask package
Submodules
dae.dask.config module
dae.dask.named_cluster module
- dae.dask.named_cluster.set_up_kubernetes_cluster(cluster_conf: dict[str, Any]) Cluster [source]
Create a kubernetes cluster.
- dae.dask.named_cluster.set_up_local_cluster(cluster_conf: dict[str, Any]) Cluster [source]
Create a local cluster using the passed cluster configuration.
- dae.dask.named_cluster.set_up_manual_client(cluster_conf: dict[str, Any]) Client [source]
Create a dask client using the passed cluster configuration.