Merge remote-tracking branch 'origin/data-lakes-survive-restart' into data-lakes-survive-restart

This commit is contained in:
kssenii 2024-01-23 11:52:13 +01:00
commit 5918ea13b7
3 changed files with 7 additions and 5 deletions

View File

@ -40,9 +40,7 @@ def list_s3_objects(minio_client, bucket, prefix=""):
prefix_len = len(prefix)
return [
obj.object_name[prefix_len:]
for obj in minio_client.list_objects(
bucket, prefix=prefix, recursive=True
)
for obj in minio_client.list_objects(bucket, prefix=prefix, recursive=True)
]

View File

@ -448,7 +448,9 @@ def test_restart_broken(started_cluster):
instance.restart_clickhouse()
assert "NoSuchBucket" in instance.query_and_get_error(f"SELECT count() FROM {TABLE_NAME}")
assert "NoSuchBucket" in instance.query_and_get_error(
f"SELECT count() FROM {TABLE_NAME}"
)
minio_client.make_bucket(bucket)

View File

@ -600,7 +600,9 @@ def test_restart_broken(started_cluster):
instance.restart_clickhouse()
assert "NoSuchBucket" in instance.query_and_get_error(f"SELECT count() FROM {TABLE_NAME}")
assert "NoSuchBucket" in instance.query_and_get_error(
f"SELECT count() FROM {TABLE_NAME}"
)
minio_client.make_bucket(bucket)