diff --git a/distributed/deploy/adaptive.py b/distributed/deploy/adaptive.py index dd4e411f5f..1ff3c6552f 100644 --- a/distributed/deploy/adaptive.py +++ b/distributed/deploy/adaptive.py @@ -133,6 +133,8 @@ def __init__( str, dask.config.get("distributed.adaptive.target-duration") ) + super().__init__(minimum=minimum, maximum=maximum, wait_count=wait_count) + self.interval = parse_timedelta(interval, "seconds") self.periodic_callback = None @@ -163,8 +165,6 @@ async def _adapt(): self.target_duration = parse_timedelta(target_duration) - super().__init__(minimum=minimum, maximum=maximum, wait_count=wait_count) - def _start(self) -> None: if self.state != "starting": return