Skip to content

Commit 62d702b

Browse files
committed
Increase sleep duration in Kafka consumer test for readiness stability
1 parent 1adbd48 commit 62d702b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

tests/test_tkvt_kafka.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ async def consumer(t, k, v, ts):
3232
await broker.consumer_loop_async(blocking=False)
3333

3434
# Wait for consumer to be ready
35-
await asyncio.sleep(2.0)
35+
await asyncio.sleep(5.0)
3636

3737
# Publish message
3838
timestamp = now()

0 commit comments

Comments
 (0)