[#306] Fix handling of bucket names in AWS CLI

- Add quotes around container names if they contain spaces or `-`.

Signed-off-by: Kirill Sosnovskikh <k.sosnovskikh@yadro.com>

src/frostfs_testlib/s3/aws_cli_client.py

@@ -70,6 +70,9 @@ class AwsCliClient(S3ClientWrapper):
         if bucket is None:
             bucket = string_utils.unique_name("bucket-")
 
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         if object_lock_enabled_for_bucket is None:
             object_lock = ""
         elif object_lock_enabled_for_bucket:
@@ -103,16 +106,25 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Delete bucket S3")
     def delete_bucket(self, bucket: str) -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = f"aws {self.common_flags} s3api delete-bucket --bucket {bucket} --endpoint {self.s3gate_endpoint} --profile {self.profile}"
         self.local_shell.exec(cmd, command_options)
 
     @reporter.step("Head bucket S3")
     def head_bucket(self, bucket: str) -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = f"aws {self.common_flags} s3api head-bucket --bucket {bucket} --endpoint {self.s3gate_endpoint} --profile {self.profile}"
         self.local_shell.exec(cmd)
 
     @reporter.step("Put bucket versioning status")
     def put_bucket_versioning(self, bucket: str, status: VersioningStatus) -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api put-bucket-versioning --bucket {bucket} "
             f"--versioning-configuration Status={status.value} "
@@ -122,6 +134,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Get bucket versioning status")
     def get_bucket_versioning_status(self, bucket: str) -> Literal["Enabled", "Suspended"]:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api get-bucket-versioning --bucket {bucket} "
             f"--endpoint {self.s3gate_endpoint} --profile {self.profile}"
@@ -132,6 +147,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Put bucket tagging")
     def put_bucket_tagging(self, bucket: str, tags: list) -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         tags_json = {"TagSet": [{"Key": tag_key, "Value": tag_value} for tag_key, tag_value in tags]}
         cmd = (
             f"aws {self.common_flags} s3api put-bucket-tagging --bucket {bucket} "
@@ -141,6 +159,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Get bucket tagging")
     def get_bucket_tagging(self, bucket: str) -> list:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api get-bucket-tagging --bucket {bucket} "
             f"--endpoint {self.s3gate_endpoint} --profile {self.profile}"
@@ -151,6 +172,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Get bucket acl")
     def get_bucket_acl(self, bucket: str) -> list:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api get-bucket-acl --bucket {bucket} " f"--endpoint {self.s3gate_endpoint} --profile {self.profile}"
         )
@@ -160,6 +184,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Get bucket location")
     def get_bucket_location(self, bucket: str) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api get-bucket-location --bucket {bucket} "
             f"--endpoint {self.s3gate_endpoint} --profile {self.profile}"
@@ -170,6 +197,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("List objects S3")
     def list_objects(self, bucket: str, full_output: bool = False) -> Union[dict, list[str]]:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = f"aws {self.common_flags} s3api list-objects --bucket {bucket} " f"--endpoint {self.s3gate_endpoint} --profile {self.profile}"
         output = self.local_shell.exec(cmd).stdout
         response = self._to_json(output)
@@ -181,6 +211,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("List objects S3 v2")
     def list_objects_v2(self, bucket: str, full_output: bool = False) -> Union[dict, list[str]]:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api list-objects-v2 --bucket {bucket} "
             f"--endpoint {self.s3gate_endpoint} --profile {self.profile}"
@@ -195,6 +228,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("List objects versions S3")
     def list_objects_versions(self, bucket: str, full_output: bool = False) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api list-object-versions --bucket {bucket} "
             f"--endpoint {self.s3gate_endpoint} --profile {self.profile}"
@@ -205,6 +241,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("List objects delete markers S3")
     def list_delete_markers(self, bucket: str, full_output: bool = False) -> list:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api list-object-versions --bucket {bucket} "
             f"--endpoint {self.s3gate_endpoint} --profile {self.profile}"
@@ -228,8 +267,13 @@ class AwsCliClient(S3ClientWrapper):
     ) -> str:
         if bucket is None:
             bucket = source_bucket
+
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         if key is None:
             key = string_utils.unique_name("copy-object-")
+
         copy_source = f"{source_bucket}/{source_key}"
 
         cmd = (
@@ -266,6 +310,9 @@ class AwsCliClient(S3ClientWrapper):
         grant_full_control: Optional[str] = None,
         grant_read: Optional[str] = None,
     ) -> str:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         if key is None:
             key = os.path.basename(filepath)
 
@@ -297,6 +344,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Head object S3")
     def head_object(self, bucket: str, key: str, version_id: Optional[str] = None) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         version = f" --version-id {version_id}" if version_id else ""
         cmd = (
             f"aws {self.common_flags} s3api head-object --bucket {bucket} --key {key} "
@@ -315,6 +365,9 @@ class AwsCliClient(S3ClientWrapper):
         object_range: Optional[tuple[int, int]] = None,
         full_output: bool = False,
     ) -> dict | TestFile:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         test_file = TestFile(os.path.join(os.getcwd(), ASSETS_DIR, string_utils.unique_name("dl-object-")))
         version = f" --version-id {version_id}" if version_id else ""
         cmd = (
@@ -329,6 +382,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Get object ACL")
     def get_object_acl(self, bucket: str, key: str, version_id: Optional[str] = None) -> list:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         version = f" --version-id {version_id}" if version_id else ""
         cmd = (
             f"aws {self.common_flags} s3api get-object-acl --bucket {bucket} --key {key} "
@@ -347,6 +403,9 @@ class AwsCliClient(S3ClientWrapper):
         grant_write: Optional[str] = None,
         grant_read: Optional[str] = None,
     ) -> list:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api put-object-acl --bucket {bucket} --key {key} "
             f" --endpoint {self.s3gate_endpoint} --profile {self.profile}"
@@ -369,6 +428,9 @@ class AwsCliClient(S3ClientWrapper):
         grant_write: Optional[str] = None,
         grant_read: Optional[str] = None,
     ) -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api put-bucket-acl --bucket {bucket} "
             f" --endpoint {self.s3gate_endpoint} --profile {self.profile}"
@@ -383,6 +445,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Delete objects S3")
     def delete_objects(self, bucket: str, keys: list[str]) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         file_path = os.path.join(os.getcwd(), ASSETS_DIR, "delete.json")
         delete_structure = json.dumps(_make_objs_dict(keys))
         with open(file_path, "w") as out_file:
@@ -399,6 +464,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Delete object S3")
     def delete_object(self, bucket: str, key: str, version_id: Optional[str] = None) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         version = f" --version-id {version_id}" if version_id else ""
         cmd = (
             f"aws {self.common_flags} s3api delete-object --bucket {bucket} "
@@ -409,6 +477,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Delete object versions S3")
     def delete_object_versions(self, bucket: str, object_versions: list) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         # Build deletion list in S3 format
         delete_list = {
             "Objects": [
@@ -435,6 +506,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Delete object versions S3 without delete markers")
     def delete_object_versions_without_dm(self, bucket: str, object_versions: list) -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         # Delete objects without creating delete markers
         for object_version in object_versions:
             self.delete_object(bucket=bucket, key=object_version["Key"], version_id=object_version["VersionId"])
@@ -450,6 +524,8 @@ class AwsCliClient(S3ClientWrapper):
         part_number: int = 0,
         full_output: bool = True,
     ) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
 
         attrs = ",".join(attributes)
         version = f" --version-id {version_id}" if version_id else ""
@@ -473,6 +549,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Get bucket policy")
     def get_bucket_policy(self, bucket: str) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api get-bucket-policy --bucket {bucket} "
             f"--endpoint {self.s3gate_endpoint} --profile {self.profile}"
@@ -483,6 +562,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Delete bucket policy")
     def delete_bucket_policy(self, bucket: str) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api delete-bucket-policy --bucket {bucket} "
             f"--endpoint {self.s3gate_endpoint} --profile {self.profile}"
@@ -493,6 +575,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Put bucket policy")
     def put_bucket_policy(self, bucket: str, policy: dict) -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         # Leaving it as is was in test repo. Double dumps to escape resulting string
         # Example:
         #  policy = {"a": 1}
@@ -508,6 +593,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Get bucket cors")
     def get_bucket_cors(self, bucket: str) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api get-bucket-cors --bucket {bucket} "
             f"--endpoint {self.s3gate_endpoint} --profile {self.profile}"
@@ -518,6 +606,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Put bucket cors")
     def put_bucket_cors(self, bucket: str, cors_configuration: dict) -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api put-bucket-cors --bucket {bucket} "
             f"--cors-configuration '{json.dumps(cors_configuration)}' --endpoint {self.s3gate_endpoint} --profile {self.profile}"
@@ -526,6 +617,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Delete bucket cors")
     def delete_bucket_cors(self, bucket: str) -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api delete-bucket-cors --bucket {bucket} "
             f"--endpoint {self.s3gate_endpoint} --profile {self.profile}"
@@ -534,6 +628,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Delete bucket tagging")
     def delete_bucket_tagging(self, bucket: str) -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api delete-bucket-tagging --bucket {bucket} "
             f"--endpoint {self.s3gate_endpoint} --profile {self.profile}"
@@ -549,6 +646,9 @@ class AwsCliClient(S3ClientWrapper):
         version_id: Optional[str] = None,
         bypass_governance_retention: Optional[bool] = None,
     ) -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         version = f" --version-id {version_id}" if version_id else ""
         cmd = (
             f"aws {self.common_flags} s3api put-object-retention --bucket {bucket} --key {key} "
@@ -566,6 +666,9 @@ class AwsCliClient(S3ClientWrapper):
         legal_hold_status: Literal["ON", "OFF"],
         version_id: Optional[str] = None,
     ) -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         version = f" --version-id {version_id}" if version_id else ""
         legal_hold = json.dumps({"Status": legal_hold_status})
         cmd = (
@@ -576,6 +679,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Put object tagging")
     def put_object_tagging(self, bucket: str, key: str, tags: list, version_id: Optional[str] = "") -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         tags = [{"Key": tag_key, "Value": tag_value} for tag_key, tag_value in tags]
         tagging = {"TagSet": tags}
         version = f" --version-id {version_id}" if version_id else ""
@@ -587,6 +693,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Get object tagging")
     def get_object_tagging(self, bucket: str, key: str, version_id: Optional[str] = None) -> list:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         version = f" --version-id {version_id}" if version_id else ""
         cmd = (
             f"aws {self.common_flags} s3api get-object-tagging --bucket {bucket} --key {key} "
@@ -598,6 +707,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Delete object tagging")
     def delete_object_tagging(self, bucket: str, key: str, version_id: Optional[str] = None) -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         version = f" --version-id {version_id}" if version_id else ""
         cmd = (
             f"aws {self.common_flags} s3api delete-object-tagging --bucket {bucket} "
@@ -613,6 +725,9 @@ class AwsCliClient(S3ClientWrapper):
         acl: Optional[str] = None,
         metadata: Optional[dict] = None,
     ) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3 sync {dir_path}  s3://{bucket} " f"--endpoint-url {self.s3gate_endpoint} --profile {self.profile}"
         )
@@ -633,6 +748,9 @@ class AwsCliClient(S3ClientWrapper):
         acl: Optional[str] = None,
         metadata: Optional[dict] = None,
     ) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3 cp {dir_path}  s3://{bucket} "
             f"--endpoint-url {self.s3gate_endpoint}  --recursive --profile {self.profile}"
@@ -648,6 +766,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Create multipart upload S3")
     def create_multipart_upload(self, bucket: str, key: str) -> str:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api create-multipart-upload --bucket {bucket} "
             f"--key {key} --endpoint-url {self.s3gate_endpoint} --profile {self.profile}"
@@ -661,6 +782,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("List multipart uploads S3")
     def list_multipart_uploads(self, bucket: str) -> Optional[list[dict]]:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api list-multipart-uploads --bucket {bucket} "
             f"--endpoint-url {self.s3gate_endpoint} --profile {self.profile}"
@@ -671,6 +795,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Abort multipart upload S3")
     def abort_multipart_upload(self, bucket: str, key: str, upload_id: str) -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api abort-multipart-upload  --bucket {bucket} "
             f"--key {key} --upload-id {upload_id} --endpoint-url {self.s3gate_endpoint} --profile {self.profile}"
@@ -679,6 +806,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Upload part S3")
     def upload_part(self, bucket: str, key: str, upload_id: str, part_num: int, filepath: str) -> str:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api upload-part --bucket {bucket} --key {key} "
             f"--upload-id {upload_id} --part-number {part_num} --body {filepath} "
@@ -691,6 +821,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Upload copy part S3")
     def upload_part_copy(self, bucket: str, key: str, upload_id: str, part_num: int, copy_source: str) -> str:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api upload-part-copy --bucket {bucket} --key {key} "
             f"--upload-id {upload_id} --part-number {part_num} --copy-source {copy_source} "
@@ -704,6 +837,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("List parts S3")
     def list_parts(self, bucket: str, key: str, upload_id: str) -> list[dict]:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api list-parts --bucket {bucket} --key {key} "
             f"--upload-id {upload_id} --endpoint-url {self.s3gate_endpoint} --profile {self.profile}"
@@ -717,6 +853,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Complete multipart upload S3")
     def complete_multipart_upload(self, bucket: str, key: str, upload_id: str, parts: list) -> None:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         file_path = os.path.join(os.getcwd(), ASSETS_DIR, "parts.json")
         parts_dict = {"Parts": [{"ETag": etag, "PartNumber": part_num} for part_num, etag in parts]}
 
@@ -737,6 +876,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Put object lock configuration")
     def put_object_lock_configuration(self, bucket: str, configuration: dict) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api put-object-lock-configuration --bucket {bucket} "
             f"--object-lock-configuration '{json.dumps(configuration)}' --endpoint-url {self.s3gate_endpoint} --profile {self.profile}"
@@ -746,6 +888,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Get object lock configuration")
     def get_object_lock_configuration(self, bucket: str):
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api get-object-lock-configuration --bucket {bucket} "
             f"--endpoint-url {self.s3gate_endpoint} --profile {self.profile}"
@@ -756,6 +901,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Put bucket lifecycle configuration")
     def put_bucket_lifecycle_configuration(self, bucket: str, lifecycle_configuration: dict, dumped_configuration: str) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api put-bucket-lifecycle-configuration --bucket {bucket} "
             f"--endpoint-url {self.s3gate_endpoint} --lifecycle-configuration file://{dumped_configuration} --profile {self.profile}"
@@ -766,6 +914,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Get bucket lifecycle configuration")
     def get_bucket_lifecycle_configuration(self, bucket: str) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api get-bucket-lifecycle-configuration --bucket {bucket} "
             f"--endpoint-url {self.s3gate_endpoint} --profile {self.profile}"
@@ -776,6 +927,9 @@ class AwsCliClient(S3ClientWrapper):
 
     @reporter.step("Delete bucket lifecycle configuration")
     def delete_bucket_lifecycle(self, bucket: str) -> dict:
+        if bucket.startswith("-") or " " in bucket:
+            bucket = f'"{bucket}"'
+
         cmd = (
             f"aws {self.common_flags} s3api delete-bucket-lifecycle --bucket {bucket} "
             f"--endpoint-url {self.s3gate_endpoint} --profile {self.profile}"