From df9615505742589fb9f602e1d49a340803915d11 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Sat, 13 May 2023 14:06:27 -0400 Subject: [PATCH] Always allow overruns in sampler context Requires https://github.com/goodboy/tractor/pull/357. Avoid overruns when doing concurrent live feed init over multiple brokers. --- piker/data/_sampling.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/piker/data/_sampling.py b/piker/data/_sampling.py index c124c95c..61ec72cb 100644 --- a/piker/data/_sampling.py +++ b/piker/data/_sampling.py @@ -351,7 +351,9 @@ async def register_with_sampler( if open_index_stream: try: - async with ctx.open_stream() as stream: + async with ctx.open_stream( + allow_overruns=True, + ) as stream: if sub_for_broadcasts: subs.add(stream)