Skip to content
Snippets Groups Projects
Commit bac6b474 authored by Antoine Lambert's avatar Antoine Lambert
Browse files

pytest_plugin: Increase poll timeout in consume_messages

This prevents flaky test_storage_replayer in swh-storage tests.
parent a38c6e7e
No related branches found
No related tags found
No related merge requests found
......@@ -51,7 +51,7 @@ def consume_messages(consumer, kafka_prefix, expected_messages):
f"Only {fetched_messages}/{expected_messages} fetched"
)
msg = consumer.poll(timeout=0.01)
msg = consumer.poll(timeout=0.1)
if not msg:
retries_left -= 1
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment