Always allow overruns in sampler context

Requires goodboy/tractor#357. Avoid overruns when doing concurrent live feed init over multiple brokers.
pikers · May 13, 2023 · df96155 · df96155
1 parent a62283b
commit df96155
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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)