Woops, fix one last `ctx._cancelled_caught` in drain loop

2024-03-08 13:48:35 -05:00 · 2024-03-08 13:48:35 -05:00 · 1617e0ff2c
parent c025761f15
commit 1617e0ff2c
1 changed files with 2 additions and 2 deletions
--- a/tractor/_context.py
+++ b/tractor/_context.py
@ -196,8 +196,8 @@ async def _drain_to_final_msg(
                    (ctx._stream.closed
                     and (reason := 'stream was already closed')
                    )
-                    or (ctx._cancelled_caught
-                        and (reason := 'ctx caught a cancel')
+                    or (ctx.cancel_acked
+                        and (reason := 'ctx cancelled other side')
                    )
                    or (ctx._cancel_called
                        and (reason := 'ctx called `.cancel()`')