Skip to content

Commit 7a4150a

Browse files
authored
PYTHON-5080 - Convert test.test_examples to async (#2097)
1 parent 8ae9a04 commit 7a4150a

File tree

7 files changed

+1580
-83
lines changed

7 files changed

+1580
-83
lines changed

test/asynchronous/helpers.py

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -381,14 +381,14 @@ def disable(self):
381381

382382

383383
class ConcurrentRunner(PARENT):
384-
def __init__(self, name, *args, **kwargs):
384+
def __init__(self, **kwargs):
385385
if _IS_SYNC:
386-
super().__init__(*args, **kwargs)
387-
self.name = name
386+
super().__init__(**kwargs)
387+
self.name = kwargs.get("name", "ConcurrentRunner")
388388
self.stopped = False
389389
self.task = None
390-
if "target" in kwargs:
391-
self.target = kwargs["target"]
390+
self.target = kwargs.get("target", None)
391+
self.args = kwargs.get("args", [])
392392

393393
if not _IS_SYNC:
394394

@@ -403,6 +403,7 @@ def is_alive(self):
403403
return not self.stopped
404404

405405
async def run(self):
406-
if self.target:
407-
await self.target()
408-
self.stopped = True
406+
try:
407+
await self.target(*self.args)
408+
finally:
409+
self.stopped = True

0 commit comments

Comments
 (0)