Skip to content

Commit

Permalink
Address feedback
Browse files Browse the repository at this point in the history
  • Loading branch information
droctothorpe committed Nov 8, 2023
1 parent 8bb815b commit 2459bbb
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions dask_kubernetes/operator/kubecluster/kubecluster.py
Original file line number Diff line number Diff line change
Expand Up @@ -116,7 +116,7 @@ class KubeCluster(Cluster):
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.
If enabled, suppress all printed output.
Defaults to ``False``.
**kwargs: dict
Expand Down Expand Up @@ -228,7 +228,6 @@ 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 Expand Up @@ -263,7 +262,7 @@ 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:``
Expand Down

0 comments on commit 2459bbb

Please sign in to comment.