From 8bb815b66b3d23fa1605814ddefaab7b16278f8d Mon Sep 17 00:00:00 2001
From: droctothorpe <alexander.perlman@capitalone.com>
Date: Fri, 3 Nov 2023 11:53:23 -0400
Subject: [PATCH] Add quiet parameter to KubeCluster

---
 dask_kubernetes/operator/kubecluster/kubecluster.py | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/dask_kubernetes/operator/kubecluster/kubecluster.py b/dask_kubernetes/operator/kubecluster/kubecluster.py
index 575fdef11..5efe6e767 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 rich console 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)
@@ -224,6 +228,7 @@ def __init__(
         self.idle_timeout = dask.config.get(
             "kubernetes.idle-timeout", override_with=idle_timeout
         )
+        self.quiet = quiet
 
         if self._custom_cluster_spec is not None:
             if isinstance(self._custom_cluster_spec, str):