diff --git a/outpostcli/lfs/storage_class/gcs.py b/outpostcli/lfs/storage_class/gcs.py index 7f6770d..96805f1 100644 --- a/outpostcli/lfs/storage_class/gcs.py +++ b/outpostcli/lfs/storage_class/gcs.py @@ -45,11 +45,6 @@ def gen_part_url(signed_url: str, part_num: int): def gen_upload_specific_url(signed_url: str, upload_id: str): return f"{signed_url}&uploadId={upload_id}" - -def gen_initiate_multipart_url(signed_url: str): - return f"{signed_url}&uploads" - - def gcs_multipart_upload(msg: Dict[str, Any]): oid = msg["oid"] filepath = msg["path"] diff --git a/outpostcli/lfs/storage_class/utils.py b/outpostcli/lfs/storage_class/utils.py index 69358da..0f8111f 100644 --- a/outpostcli/lfs/storage_class/utils.py +++ b/outpostcli/lfs/storage_class/utils.py @@ -33,6 +33,7 @@ def part_dict_list_to_xml(multi_parts: List[UploadedPartObject]): @handle_request_errors @retry( + reraise=True, stop=stop_after_attempt(4), # Maximum number of retries wait=wait_exponential(multiplier=1, min=1, max=60), # Exponential backoff ) @@ -44,6 +45,7 @@ def complete_multipart_upload(url: str, parts: List[UploadedPartObject]): @handle_request_errors @retry( + reraise=True, stop=stop_after_attempt(4), # Maximum number of retries wait=wait_exponential(multiplier=1, min=1, max=60), # Exponential backoff ) @@ -58,6 +60,7 @@ def initiate_multipart_upload(url: str) -> str: @handle_request_errors @retry( + reraise=True, stop=stop_after_attempt(4), # Maximum number of retries wait=wait_exponential(multiplier=1, min=1, max=60), # Exponential backoff )