From c0dae89af3f747bb2c4060d37ed2f5a5e689716e Mon Sep 17 00:00:00 2001 From: goodboy Date: Thu, 24 Sep 2026 14:24:14 -0400 Subject: [PATCH] Use public `tractor.Context.cancel_called` property --- piker/data/_sampling.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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'