File tree Expand file tree Collapse file tree 1 file changed +3
-5
lines changed
services/storage/src/simcore_service_storage/api/_worker_tasks Expand file tree Collapse file tree 1 file changed +3
-5
lines changed Original file line number Diff line number Diff line change 22
33from celery import Task # type: ignore[import-untyped]
44from models_library .api_schemas_storage .storage_schemas import (
5- ETag ,
65 FileUploadCompletionBody ,
76)
87from models_library .projects_nodes_io import LocationID , StorageFileID
98from models_library .users import UserID
109from servicelib .logging_utils import log_context
1110
1211from ...dsm import get_dsm_provider
12+ from ...models import FileMetaData
1313from ...modules .celery .utils import get_fastapi_app
1414
1515_logger = logging .getLogger (__name__ )
@@ -21,7 +21,7 @@ async def complete_upload_file(
2121 location_id : LocationID ,
2222 file_id : StorageFileID ,
2323 body : FileUploadCompletionBody ,
24- ) -> ETag | None :
24+ ) -> FileMetaData :
2525 with log_context (
2626 _logger ,
2727 logging .INFO ,
@@ -31,6 +31,4 @@ async def complete_upload_file(
3131 # NOTE: completing a multipart upload on AWS can take up to several minutes
3232 # if it returns slow we return a 202 - Accepted, the client will have to check later
3333 # for completeness
34- file_meta_data = await dsm .complete_file_upload (file_id , user_id , body .parts )
35-
36- return file_meta_data .entity_tag
34+ return await dsm .complete_file_upload (file_id , user_id , body .parts )
You can’t perform that action at this time.
0 commit comments