diff --git a/adaptive/runner.py b/adaptive/runner.py index cf0d4d2cd..9e2fa1f21 100644 --- a/adaptive/runner.py +++ b/adaptive/runner.py @@ -6,6 +6,7 @@ import itertools import pickle import platform +import sys import time import traceback import warnings @@ -640,9 +641,8 @@ async def _run(self): try: while not self.goal(self.learner): futures = self._get_futures() - done, _ = await asyncio.wait( - futures, return_when=first_completed, loop=self.ioloop - ) + kw = {"loop": self.ioloop} if sys.version_info[:2] < (3, 10) else {} + done, _ = await asyncio.wait(futures, return_when=first_completed, **kw) self._process_futures(done) finally: remaining = self._remove_unfinished()