Source code for dask_kubernetes.aiopykube.dask

from dask_kubernetes.aiopykube.objects import NamespacedAPIObject



[docs]class DaskCluster(NamespacedAPIObject):
    version = "kubernetes.dask.org/v1"
    endpoint = "daskclusters"
    kind = "DaskCluster"




[docs]class DaskWorkerGroup(NamespacedAPIObject):
    version = "kubernetes.dask.org/v1"
    endpoint = "daskworkergroups"
    kind = "DaskWorkerGroup"




[docs]class DaskAutoscaler(NamespacedAPIObject):
    version = "kubernetes.dask.org/v1"
    endpoint = "daskautoscalers"
    kind = "DaskAutoscaler"




[docs]class DaskJob(NamespacedAPIObject):
    version = "kubernetes.dask.org/v1"
    endpoint = "daskjobs"
    kind = "DaskJob"