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

Merge remote-tracking branch 'origin/fix-usage-of-plain-metadata' into fix-usage-of-plain-metadata

Browse Source
This commit is contained in:
kssenii 2024-02-27 17:35:24 +08:00
commit a284e711da
1 changed files with 36 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -20,27 +20,57 @@ def start_cluster():
finally:
cluster.shutdown()
s3_disk_def = """disk(type=s3_plain,
endpoint='http://minio1:9001/root/data/disks/disk_s3_plain/{}/',
access_key_id='minio',
secret_access_key='minio123');"""
local_disk_def = "disk(type=object_storage, object_storage_type = 'local_blob_storage', metadata_type = 'plain', path = '/local_plain/{}/')"
local_disk_def = (
"disk(type=object_storage, object_storage_type = 'local', metadata_type = 'plain', path = '/local_plain/{}/'"
)
@pytest.mark.parametrize(
"table_name,backup_name,storage_policy,disk_def,min_bytes_for_wide_part",
[
pytest.param(
"compact", "backup_compact_s3", "backup_disk_s3_plain", s3_disk_def, int(1e9), id="compact"
"compact",
"backup_compact_s3",
"backup_disk_s3_plain",
s3_disk_def,
int(1e9),
id="compact",
),
pytest.param("wide", "backup_wide_s3", "backup_disk_s3_plain", s3_disk_def, int(0), id="wide"),
pytest.param(
"compact", "backup_compact_local", "backup_disk_local_plain", local_disk_def, int(1e9), id="compact"
"wide",
"backup_wide_s3",
"backup_disk_s3_plain",
s3_disk_def,
int(0),
id="wide",
),
pytest.param(
"compact",
"backup_compact_local",
"backup_disk_local_plain",
local_disk_def,
int(1e9),
id="compact",
),
pytest.param(
"wide",
"backup_wide_local",
"backup_disk_local_plain",
local_disk_def,
int(0),
id="wide",
),
pytest.param("wide", "backup_wide_local", "backup_disk_local_plain", local_disk_def, int(0), id="wide"),
],
)
def test_attach_part(table_name, backup_name, storage_policy, disk_def, min_bytes_for_wide_part):
def test_attach_part(
table_name, backup_name, storage_policy, disk_def, min_bytes_for_wide_part
):
disk_definition = disk_def.format(backup_name)
node.query(
f"""