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 abad155 commit 3247e21Copy full SHA for 3247e21
adaptive/runner.py
@@ -641,11 +641,8 @@ async def _run(self):
641
try:
642
while not self.goal(self.learner):
643
futures = self._get_futures()
644
- done, _ = await asyncio.wait(
645
- futures,
646
- return_when=first_completed,
647
- loop=self.ioloop if sys.version_info[:2] < (3, 10) else None,
648
- )
+ kw = {"loop": self.ioloop} if sys.version_info[:2] < (3, 10) else {}
+ done, _ = await asyncio.wait(futures, return_when=first_completed, **kw)
649
self._process_futures(done)
650
finally:
651
remaining = self._remove_unfinished()
0 commit comments