fix: Don't swallow caller cancellation in AsyncRepeatingTask.wait_stopped

wait_stopped awaited the worker with a bare await + except CancelledError, which conflated the worker's expected stop() cancellation with cancellation of the caller itself — a timed/cancelled stop() could swallow the cancel and return as if it completed. Use asyncio.wait({task}) (as join_handle already does): it absorbs the worker's cancellation without re-raising it, while still propagating a cancellation of the caller.

Author: jsonbailey

ldclient/impl/aio/concurrency.py

@@ -228,10 +228,7 @@ async def wait_stopped(self):
         the task never started or is the current task."""
         task = self.__task
         if task is not None and task is not asyncio.current_task():
-            try:
-                await task
-            except asyncio.CancelledError:
-                pass
+            await asyncio.wait({task})
 
     async def _run(self):
         try: