Fix cluster test to use `allow_overruns`

proper_breakpoint_hooking
Tyler Goodlet 2023-04-13 17:48:57 -04:00
parent 45f601a035
commit 6aa780d0cd
1 changed files with 1 additions and 1 deletions

View File

@ -49,7 +49,7 @@ async def worker(
await ctx.started() await ctx.started()
async with ctx.open_stream( async with ctx.open_stream(
backpressure=True, allow_overruns=True,
) as stream: ) as stream:
# TODO: this with the below assert causes a hang bug? # TODO: this with the below assert causes a hang bug?