Skip to content

Commit

Permalink
Add quiet parameter to KubeCluster
Browse files Browse the repository at this point in the history
  • Loading branch information
droctothorpe committed Nov 3, 2023
1 parent fa7255b commit 8bb815b
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions dask_kubernetes/operator/kubecluster/kubecluster.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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)
Expand Down Expand Up @@ -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):
Expand Down

0 comments on commit 8bb815b

Please sign in to comment.