|
3 | 3 | from pathlib import Path |
4 | 4 |
|
5 | 5 | import arrow |
6 | | -from aws_library.s3._errors import S3KeyNotFoundError |
7 | 6 | from fastapi import FastAPI |
8 | 7 | from models_library.api_schemas_storage.storage_schemas import ( |
9 | 8 | DatCoreCollectionName, |
|
32 | 31 | from .modules.datcore_adapter import datcore_adapter |
33 | 32 | from .modules.datcore_adapter.datcore_adapter_exceptions import ( |
34 | 33 | DatcoreAdapterMultipleFilesError, |
35 | | - DatcoreAdapterResponseError, |
36 | 34 | ) |
37 | 35 | from .modules.db.tokens import get_api_token_and_secret |
38 | 36 |
|
@@ -279,13 +277,9 @@ async def create_file_download_link( |
279 | 277 | ) -> AnyUrl: |
280 | 278 | api_token, api_secret = await self._get_datcore_tokens(user_id) |
281 | 279 | api_token, api_secret = _check_api_credentials(api_token, api_secret) |
282 | | - try: |
283 | | - return await datcore_adapter.get_file_download_presigned_link( |
284 | | - self.app, api_token, api_secret, file_id |
285 | | - ) |
286 | | - except DatcoreAdapterResponseError as exc: |
287 | | - if exc.status == status.HTTP_404_NOT_FOUND: |
288 | | - raise S3KeyNotFoundError(key=file_id, bucket=self.buck) |
| 280 | + return await datcore_adapter.get_file_download_presigned_link( |
| 281 | + self.app, api_token, api_secret, file_id |
| 282 | + ) |
289 | 283 |
|
290 | 284 | async def delete_file(self, user_id: UserID, file_id: StorageFileID) -> None: |
291 | 285 | api_token, api_secret = await self._get_datcore_tokens(user_id) |
|
0 commit comments