increase timeouts for kafka

Altinity · Oct 16, 2024 · be3bdff · be3bdff
1 parent 9cad1ef
commit be3bdff
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/sink-connector/tests/integration/tests/deduplication.py b/sink-connector/tests/integration/tests/deduplication.py
@@ -45,7 +45,7 @@ def deduplication(
             statement="count(*)",
             clickhouse_table=clickhouse_table,
             with_final=True,
-            timeout=50,
+            timeout=140,
         )
 
 

diff --git a/sink-connector/tests/integration/tests/partition_limits.py b/sink-connector/tests/integration/tests/partition_limits.py
@@ -58,7 +58,7 @@ def partition_limits(
 
                 retry(
                     clickhouse.query,
-                    timeout=50,
+                    timeout=140,
                     delay=1,
                 )(
                     f"SELECT count() FROM test.{table_name}  FINAL where _sign !=-1  FORMAT CSV",

diff --git a/sink-connector/tests/integration/tests/steps/sql.py b/sink-connector/tests/integration/tests/steps/sql.py
@@ -293,7 +293,7 @@ def complex_check_creation_and_select(
     table_name,
     clickhouse_table,
     statement,
-    timeout=50,
+    timeout=140,
     message=1,
     clickhouse_node=None,
     database_name=None,