diff --git a/piker/data/_sampling.py b/piker/data/_sampling.py index 98a7603f..01c5a35e 100644 --- a/piker/data/_sampling.py +++ b/piker/data/_sampling.py @@ -529,7 +529,9 @@ async def open_sample_stream( assert len(first) > 1 async with ( - ctx.open_stream() as istream, + ctx.open_stream( + allow_overruns=True, + ) as istream, # TODO: we DO need this task-bcasting so that # for eg. the history chart update loop eventually