From 6977d982192c3b4397fc7197f45f7503b84f802f Mon Sep 17 00:00:00 2001 From: Stephen Balogh Date: Thu, 20 Aug 2026 20:28:39 -0700 Subject: [PATCH] remove wait param in correctness test --- tests/test_correctness.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tests/test_correctness.py b/tests/test_correctness.py index 8f1f5d1..fd56dd2 100644 --- a/tests/test_correctness.py +++ b/tests/test_correctness.py @@ -38,7 +38,7 @@ async def read_records() -> None: last_seq_num: int | None = None num_records_read = 0 - async with stream.read_session(start=SeqNum(0), wait=60) as session: + async with stream.read_session(start=SeqNum(0)) as session: async for batch in session: for record in batch.records: seq_num = record.seq_num @@ -89,7 +89,7 @@ async def test_read_session_reports_caught_up_after_delivering_tail(stream: S2St AppendInput(records=[Record(body=b"first"), Record(body=b"second")]) ) - async with stream.read_session(start=TailOffset(2), wait=60) as session: + async with stream.read_session(start=TailOffset(2)) as session: caught_up = session.caught_up() records = []