Skip to content

Commit 54473b0

Browse files
committed
Fix Minio calls due to API change
1 parent 5a094f2 commit 54473b0

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

elt-common/tests/e2e_tests/conftest.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -339,14 +339,14 @@ def warehouse(server: Server, project: uuid.UUID) -> Generator:
339339
# Ensure bucket exists
340340
s3_hostname = urllib.parse.urlparse(storage_config["storage-profile"]["endpoint"]).netloc
341341
minio_client = Minio(
342-
s3_hostname,
342+
endpoint=s3_hostname,
343343
access_key=storage_config["storage-credential"]["aws-access-key-id"],
344344
secret_key=storage_config["storage-credential"]["aws-secret-access-key"],
345345
secure=False,
346346
)
347347
bucket_name = storage_config["storage-profile"]["bucket"]
348-
if not minio_client.bucket_exists(bucket_name):
349-
minio_client.make_bucket(bucket_name)
348+
if not minio_client.bucket_exists(bucket_name=bucket_name):
349+
minio_client.make_bucket(bucket_name=bucket_name)
350350
print(f"Bucket {bucket_name} created.")
351351

352352
warehouse = server.create_warehouse(settings.warehouse_name, project, storage_config)
@@ -357,7 +357,7 @@ def warehouse(server: Server, project: uuid.UUID) -> Generator:
357357

358358
@tenacity.retry(**_RETRY_ARGS)
359359
def _remove_bucket(bucket_name):
360-
minio_client.remove_bucket(bucket_name)
360+
minio_client.remove_bucket(bucket_name=bucket_name)
361361

362362
try:
363363
server.purge_warehouse(warehouse)

0 commit comments

Comments
 (0)