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.master
parent
a62283bae2
commit
df96155057
|
@ -351,7 +351,9 @@ async def register_with_sampler(
|
||||||
|
|
||||||
if open_index_stream:
|
if open_index_stream:
|
||||||
try:
|
try:
|
||||||
async with ctx.open_stream() as stream:
|
async with ctx.open_stream(
|
||||||
|
allow_overruns=True,
|
||||||
|
) as stream:
|
||||||
if sub_for_broadcasts:
|
if sub_for_broadcasts:
|
||||||
subs.add(stream)
|
subs.add(stream)
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue