thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-09-19 16:20:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Automatic style fix

Browse Source
This commit is contained in:
robot-clickhouse 2023-04-17 16:17:02 +00:00
parent 51c9ae05fb
commit c53f2b763f
1 changed files with 28 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
tests/integration/test_zero_copy_replication_drop_detached_part/test.py
View File

@ -52,25 +52,39 @@ ORDER BY (CounterID, EventDate)"""
return row
path_to_detached_part = get_path_to_detached_part(
node1.query(
"SELECT path FROM system.detached_parts where table = 'test1'"
)
node1.query("SELECT path FROM system.detached_parts where table = 'test1'")
)
new_part_name = "ignored_" + os.path.basename(path_to_detached_part)
new_path_to_detached_part_name = os.path.dirname(path_to_detached_part) + os.sep + new_part_name
new_path_to_detached_part_name = (
os.path.dirname(path_to_detached_part) + os.sep + new_part_name
)
node1.exec_in_container(
[
"bash",
"-c",
f"mv {path_to_detached_part} {new_path_to_detached_part_name}",
],
privileged=True,
user="root")
[
"bash",
"-c",
f"mv {path_to_detached_part} {new_path_to_detached_part_name}",
],
privileged=True,
user="root",
)
assert node1.query("SELECT path FROM system.detached_parts where table = 'test1'").strip() == new_path_to_detached_part_name
assert (
node1.query(
"SELECT path FROM system.detached_parts where table = 'test1'"
).strip()
== new_path_to_detached_part_name
)
node1.query(f"ALTER TABLE test1 DROP DETACHED PART '{new_part_name}'", settings={"allow_drop_detached": 1})
node1.query(
f"ALTER TABLE test1 DROP DETACHED PART '{new_part_name}'",
settings={"allow_drop_detached": 1},
)
assert node1.query("SELECT path FROM system.detached_parts where table = 'test1'").strip() == ""
assert (
node1.query(
"SELECT path FROM system.detached_parts where table = 'test1'"
).strip()
== ""
)