thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-10 09:32:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Try to fix flaky s3 tests test_seekable_formats and test_seekable_formats_url

Browse Source
This commit is contained in:
avogar 2024-05-13 16:33:38 +00:00
parent 67cf40810a
commit 927ba761a3
2 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/integration/helpers/test_tools.py
View File

@ -139,7 +139,7 @@ def assert_logs_contain_with_retry(instance, substring, retry_count=20, sleep_ti
def exec_query_with_retry(
instance, query, retry_count=40, sleep_time=0.5, silent=False, settings={}
instance, query, retry_count=40, sleep_time=0.5, silent=False, settings={}, timeout=30
):
exception = None
for cnt in range(retry_count):

4
tests/integration/test_storage_s3/test.py
View File

@ -1133,6 +1133,7 @@ def test_seekable_formats(started_cluster):
exec_query_with_retry(
instance,
f"insert into table function {table_function} SELECT number, randomString(100) FROM numbers(1000000) settings s3_truncate_on_insert=1",
timeout=100,
)
result = instance.query(f"SELECT count() FROM {table_function}")
@ -1142,6 +1143,7 @@ def test_seekable_formats(started_cluster):
exec_query_with_retry(
instance,
f"insert into table function {table_function} SELECT number, randomString(100) FROM numbers(1500000) settings s3_truncate_on_insert=1",
timeout=100,
)
result = instance.query(
@ -1169,6 +1171,7 @@ def test_seekable_formats_url(started_cluster):
exec_query_with_retry(
instance,
f"insert into table function {table_function} SELECT number, randomString(100) FROM numbers(1500000) settings s3_truncate_on_insert=1",
timeout=100,
)
result = instance.query(f"SELECT count() FROM {table_function}")
@ -1178,6 +1181,7 @@ def test_seekable_formats_url(started_cluster):
exec_query_with_retry(
instance,
f"insert into table function {table_function} SELECT number, randomString(100) FROM numbers(1500000) settings s3_truncate_on_insert=1",
timeout=100,
)
table_function = f"url('http://{started_cluster.minio_host}:{started_cluster.minio_port}/{bucket}/test_parquet', 'Parquet', 'a Int32, b String')"