Increase timeouts in tests

Author: gwaramadze

tests/test_quixstreams/test_app.py

@@ -3194,7 +3194,7 @@ def test_run_with_timeout_resets_after_recovery(
         """
         Timeout is set only after recovery is complete
         """
-        timeout = 1.0
+        timeout = 3.0
 
         app = app_factory(
             auto_offset_reset="earliest",

tests/test_quixstreams/test_kafka/test_consumer.py

@@ -70,7 +70,7 @@ def test_consumer_subscribe_topic_doesnt_exist(self, consumer):
 
         with consumer:
             consumer.subscribe(topics=[topic_name])
-            msg = consumer.poll(timeout=1)
+            msg = consumer.poll(timeout=3)
             assert msg
             err = msg.error()
             assert err.code() == KafkaError.UNKNOWN_TOPIC_OR_PART

tests/test_quixstreams/test_sources/test_core/test_kafka.py

@@ -32,7 +32,7 @@ def external_kafka(self, external_kafka_container):
 
     @pytest.fixture()
     def app(self, app_factory):
-        return app_factory(auto_offset_reset="earliest", request_timeout=1)
+        return app_factory(auto_offset_reset="earliest", request_timeout=3)
 
 
 class TestKafkaReplicatorSource(Base):