thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-27 01:51:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove logging traces to help debugging

Browse Source
This commit is contained in:
Pablo Marcos 2024-07-29 11:15:03 +00:00
parent 5b9427dc56
commit 4cf7e6a79d
1 changed files with 2 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -858,17 +858,12 @@ def test_max_set_age(started_cluster):
def get_count():
return int(node.query(f"SELECT count() FROM {dst_table_name}"))
import os
def wait_for_condition(check_function, max_wait_time=1.5 * max_age):
logging.debug(f"{os.getenv('PYTEST_XDIST_WORKER')} - PMO: Waiting for condition")
before = time.time()
while time.time() - before < max_wait_time:
if check_function():
logging.debug(f"{os.getenv('PYTEST_XDIST_WORKER')} - PMO: Condition verified")
return
time.sleep(0.25)
logging.debug(f"{os.getenv('PYTEST_XDIST_WORKER')} - PMO: Oh oh... Condition not verified")
assert False
wait_for_condition(lambda: get_count() == expected_rows)
@ -889,12 +884,8 @@ def test_max_set_age(started_cluster):
).splitlines()
]
assert files_to_generate == len(paths_count)
try:
for path_count in paths_count:
assert 2 == path_count
finally:
logging.debug(f"{os.getenv('PYTEST_XDIST_WORKER')} - PMO: Got path count {path_count} for paths_count {paths_count}")
logging.debug(f"{os.getenv('PYTEST_XDIST_WORKER')} - PMO: Got paths: {node.query('SELECT *, _path from ' + dst_table_name + ' FORMAT JSONEachRow')}")
for path_count in paths_count:
assert 2 == path_count
def get_object_storage_failures():
return int(
@ -904,7 +895,6 @@ def test_max_set_age(started_cluster):
)
failed_count = get_object_storage_failures()
logging.debug(f"{os.getenv('PYTEST_XDIST_WORKER')} - PMO: Got failed count {failed_count}")
values = [
["failed", 1, 1],