Commit e208d1d4 authored by Christophe Lallement's avatar Christophe Lallement
Browse files

stop catching azure exceptions

parent cedf155c
Pipeline #44483 failed with stage
in 2 minutes and 1 second
...@@ -77,7 +77,6 @@ class AzureAioBlobStorage(BlobStorageBase): ...@@ -77,7 +77,6 @@ class AzureAioBlobStorage(BlobStorageBase):
async def _get_storage_account_name(self, data_partition_id: str): async def _get_storage_account_name(self, data_partition_id: str):
return await PartitionService.get_storage_account_name(data_partition_id) return await PartitionService.get_storage_account_name(data_partition_id)
@with_blobstorage_exception(ExceptionMapping)
async def list_objects(self, tenant: Tenant, async def list_objects(self, tenant: Tenant,
*args, auth: Optional = None, prefix: str = '', page_token: Optional[str] = None, *args, auth: Optional = None, prefix: str = '', page_token: Optional[str] = None,
max_result: Optional[int] = None, timeout: int = 10, **kwargs) -> List[str]: max_result: Optional[int] = None, timeout: int = 10, **kwargs) -> List[str]:
...@@ -103,7 +102,6 @@ class AzureAioBlobStorage(BlobStorageBase): ...@@ -103,7 +102,6 @@ class AzureAioBlobStorage(BlobStorageBase):
break break
return result return result
@with_blobstorage_exception(ExceptionMapping)
async def delete(self, tenant: Tenant, object_name: str, async def delete(self, tenant: Tenant, object_name: str,
*args, auth: Optional = None, timeout: int = 10, **kwargs): *args, auth: Optional = None, timeout: int = 10, **kwargs):
""" """
...@@ -121,7 +119,6 @@ class AzureAioBlobStorage(BlobStorageBase): ...@@ -121,7 +119,6 @@ class AzureAioBlobStorage(BlobStorageBase):
container_client = blob_service_client.get_container_client(container) container_client = blob_service_client.get_container_client(container)
await container_client.delete_blob(object_name) await container_client.delete_blob(object_name)
@with_blobstorage_exception(ExceptionMapping)
async def download(self, tenant: Tenant, object_name: str, async def download(self, tenant: Tenant, object_name: str,
*args, auth: Optional = None, timeout: int = 10, **kwargs) -> bytes: *args, auth: Optional = None, timeout: int = 10, **kwargs) -> bytes:
""" """
...@@ -142,7 +139,6 @@ class AzureAioBlobStorage(BlobStorageBase): ...@@ -142,7 +139,6 @@ class AzureAioBlobStorage(BlobStorageBase):
return await data.readall() return await data.readall()
# not for now, parquet only # not for now, parquet only
@with_blobstorage_exception(ExceptionMapping)
async def download_metadata(self, tenant: Tenant, object_name: str, async def download_metadata(self, tenant: Tenant, object_name: str,
*args, auth: Optional = None, timeout: int = 10, **kwargs) -> Blob: *args, auth: Optional = None, timeout: int = 10, **kwargs) -> Blob:
""" """
...@@ -178,7 +174,6 @@ class AzureAioBlobStorage(BlobStorageBase): ...@@ -178,7 +174,6 @@ class AzureAioBlobStorage(BlobStorageBase):
provider_specific=properties provider_specific=properties
) )
@with_blobstorage_exception(ExceptionMapping)
async def upload(self, tenant: Tenant, object_name: str, file_data: Any, *, async def upload(self, tenant: Tenant, object_name: str, file_data: Any, *,
overwrite: bool = True, overwrite: bool = True,
if_match=None, if_match=None,
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment