thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-15 20:24:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove change

Browse Source
This commit is contained in:
kssenii 2024-10-24 20:19:46 +02:00
parent 0eddccbcc5
commit 0f66694468
1 changed files with 0 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
tests/integration/test_storage_s3_queue/test.py
View File

@ -1644,24 +1644,6 @@ def test_processed_file_setting(started_cluster, processing_threads):
assert expected_rows == get_count()
node.restart_clickhouse()
correct_values = [
[1, 1, 1],
]
values_csv = (
"\n".join((",".join(map(str, row)) for row in correct_values)) + "\n"
).encode()
file_path = f"{files_path}/test_99.csv"
put_s3_file_content(started_cluster, file_path, values_csv)
expected_rows += 1
for _ in range(20):
if expected_rows == get_count():
break
time.sleep(1)
assert expected_rows == get_count()
@pytest.mark.parametrize("processing_threads", [1, 5])
def test_processed_file_setting_distributed(started_cluster, processing_threads):