Merge branch 'main' of github.com:dask/dask-kubernetes into operator-…

…priority-class

.github/workflows/operator.yaml

@@ -28,7 +28,7 @@ jobs:
       - uses: actions/checkout@v2
       - name: Lint Helm Chart
         run: helm lint dask_kubernetes/operator/deployment/helm/dask-kubernetes-operator
-      - name: Download Pluto
+      - name: Install Pluto
         uses: FairwindsOps/pluto/[email protected]
       - name: Check for deprecated APIs
         run: helm template --include-crds dask-operator dask_kubernetes/operator/deployment/helm/dask-kubernetes-operator | pluto detect -

dask_kubernetes/operator/kubecluster/kubecluster.py

@@ -115,6 +115,9 @@ class KubeCluster(Cluster):
         used to create the cluster instead of generating one from the other keyword arguments.
     scheduler_forward_port: int (optional)
         The port to use when forwarding the scheduler dashboard. Will utilize a random port by default
+    quiet: bool
+        If enabled, suppress all printed output.
+        Defaults to ``False``.
 
     **kwargs: dict
         Additional keyword arguments to pass to LocalCluster
@@ -175,6 +178,7 @@ def __init__(
         jupyter: bool = False,
         loop: Optional[IOLoop] = None,
         asynchronous: bool = False,
+        quiet: bool = False,
         **kwargs,
     ):
         name = dask.config.get("kubernetes.name", override_with=name)
@@ -258,7 +262,9 @@ def __init__(
         self._rich_spinner = Spinner("dots", speed=0.5)
         self._startup_component_status: dict = {}
 
-        super().__init__(name=name, loop=loop, asynchronous=asynchronous, **kwargs)
+        super().__init__(
+            name=name, loop=loop, asynchronous=asynchronous, quiet=quiet, **kwargs
+        )
 
         # If https://github.com/dask/distributed/pull/7941 is merged we can
         # simplify the next 8 lines to ``if not self.called_from_running_loop:``

requirements.txt

@@ -5,4 +5,4 @@ kubernetes-asyncio>=12.0.1
 kopf>=1.35.3
 pykube-ng>=22.9.0
 rich>=12.5.1
-kr8s>=0.9.0
+kr8s==0.9.0