Avoid mutate on iterate race

2021-06-10 13:59:08 -04:00 · 2021-06-10 13:59:08 -04:00 · 8f25f2d2fa
parent 8297e765c1
commit 8f25f2d2fa
1 changed files with 4 additions and 1 deletions
--- a/tractor/_actor.py
+++ b/tractor/_actor.py
@ -523,11 +523,14 @@ class Actor:
                task_status.started(loop_cs)
                async for msg in chan:
                    if msg is None:  # loop terminate sentinel
+
                        log.debug(
                            f"Cancelling all tasks for {chan} from {chan.uid}")
-                        for (channel, cid) in self._rpc_tasks:
+
+                        for (channel, cid) in self._rpc_tasks.copy():
                            if channel is chan:
                                await self._cancel_task(cid, channel)
+
                        log.debug(
                                f"Msg loop signalled to terminate for"
                                f" {chan} from {chan.uid}")