diff --git a/piker/data/_sampling.py b/piker/data/_sampling.py
index 83afe321..4f9b3d9d 100644
--- a/piker/data/_sampling.py
+++ b/piker/data/_sampling.py
@@ -781,7 +781,7 @@ async def sample_and_broadcast(
                                     # channel-ipc-pipe is still up.
                                     if (
                                         not chan.connected()
-                                        or ctx._cancel_called
+                                        or ctx.cancel_called
                                     ):
                                         log.warning(
                                             'Dropping broken consumer:\n'