From 31079dec6eabc259d8c4cf2cb9fd08ee90270064 Mon Sep 17 00:00:00 2001 From: Jacob Tomlinson Date: Fri, 5 Jan 2024 10:54:20 +0000 Subject: [PATCH 1/3] Pin kr8s to 0.9.0 (#852) --- .github/workflows/operator.yaml | 2 +- requirements.txt | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/.github/workflows/operator.yaml b/.github/workflows/operator.yaml index 5a8bb230f..3eec45023 100644 --- a/.github/workflows/operator.yaml +++ b/.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/github-action@v5.11.1 - name: Check for deprecated APIs run: helm template --include-crds dask-operator dask_kubernetes/operator/deployment/helm/dask-kubernetes-operator | pluto detect - diff --git a/requirements.txt b/requirements.txt index d7a850edf..665275ceb 100644 --- a/requirements.txt +++ b/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 From ff71342802e9e76ebede93fe1311761775b7a95a Mon Sep 17 00:00:00 2001 From: Jacob Tomlinson Date: Fri, 5 Jan 2024 11:36:25 +0000 Subject: [PATCH 2/3] Release 2024.1.0 From eeb3c409362f0ae7b59f105c7a068daf2d29b583 Mon Sep 17 00:00:00 2001 From: Alex Date: Fri, 5 Jan 2024 08:45:22 -0500 Subject: [PATCH 3/3] Add quiet parameter to KubeCluster (#840) * Add quiet parameter to KubeCluster * Address feedback --------- Co-authored-by: Jacob Tomlinson --- dask_kubernetes/operator/kubecluster/kubecluster.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/dask_kubernetes/operator/kubecluster/kubecluster.py b/dask_kubernetes/operator/kubecluster/kubecluster.py index 575fdef11..d5891ab4a 100644 --- a/dask_kubernetes/operator/kubecluster/kubecluster.py +++ b/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:``