We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 004fafb commit ecee9e8Copy full SHA for ecee9e8
distributed/deploy/adaptive.py
@@ -133,6 +133,8 @@ def __init__(
133
str, dask.config.get("distributed.adaptive.target-duration")
134
)
135
136
+ super().__init__(minimum=minimum, maximum=maximum, wait_count=wait_count)
137
+
138
self.interval = parse_timedelta(interval, "seconds")
139
self.periodic_callback = None
140
@@ -163,8 +165,6 @@ async def _adapt():
163
165
164
166
self.target_duration = parse_timedelta(target_duration)
167
- super().__init__(minimum=minimum, maximum=maximum, wait_count=wait_count)
-
168
def _start(self) -> None:
169
if self.state != "starting":
170
return
0 commit comments