simple fix for CI failure

This commit is contained in:
Mikhail Filimonov 2021-02-26 06:41:11 +01:00
parent c4470ff283
commit 60ede36068
No known key found for this signature in database
GPG Key ID: 6E49C2E9AF1220BE

View File

@ -2441,6 +2441,7 @@ def test_kafka_unavailable(kafka_cluster):
instance.wait_for_log_line("Committed offset 2000")
assert int(instance.query("SELECT count() FROM test.destination")) == 2000
time.sleep(5) # needed to give time for kafka client in python test to recovery
@pytest.mark.timeout(180)
def test_kafka_issue14202(kafka_cluster):