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 a596bcd commit 59edcd7Copy full SHA for 59edcd7
adaptive/runner.py
@@ -6,6 +6,7 @@
6
import itertools
7
import pickle
8
import platform
9
+import sys
10
import time
11
import traceback
12
import warnings
@@ -640,9 +641,8 @@ async def _run(self):
640
641
try:
642
while not self.goal(self.learner):
643
futures = self._get_futures()
- done, _ = await asyncio.wait(
644
- futures, return_when=first_completed, loop=self.ioloop
645
- )
+ kw = {"loop": self.ioloop} if sys.version_info[:2] < (3, 10) else {}
+ done, _ = await asyncio.wait(futures, return_when=first_completed, **kw)
646
self._process_futures(done)
647
finally:
648
remaining = self._remove_unfinished()
0 commit comments