Fix missing await

2020-10-13 00:45:29 -04:00 · 2020-10-13 00:45:29 -04:00 · c41e5c8313
parent a88a6ba7a3
commit c41e5c8313
1 changed files with 1 additions and 1 deletions
--- a/tractor/_actor.py
+++ b/tractor/_actor.py
@ -541,7 +541,7 @@ class Actor:
                    # channel disconnect
                    log.debug(
                        f"{chan} from {chan.uid} disconnected, cancelling all rpc tasks")
-                    self.cancel_rpc_tasks(chan)
+                    await self.cancel_rpc_tasks(chan)

        except trio.ClosedResourceError:
            log.error(f"{chan} form {chan.uid} broke")