From bbfbe43510cb18962f78c5a6d80e6081349c4d8f Mon Sep 17 00:00:00 2001 From: zhiren Date: Wed, 26 Apr 2023 09:16:06 -0400 Subject: [PATCH] fixup the core zone cannot resume the upload --- app/services/file_manager/file_upload/file_upload.py | 3 ++- app/services/file_manager/file_upload/upload_client.py | 1 + 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/app/services/file_manager/file_upload/file_upload.py b/app/services/file_manager/file_upload/file_upload.py index bbfc8682..ee694a90 100644 --- a/app/services/file_manager/file_upload/file_upload.py +++ b/app/services/file_manager/file_upload/file_upload.py @@ -117,7 +117,7 @@ def simple_upload( # noqa: C901 tags = upload_event.get('tags') zone = upload_event.get('zone') # process_pipeline = upload_event.get('process_pipeline', None) - # upload_message = upload_event.get('upload_message') + upload_message = upload_event.get('upload_message') current_folder_node = upload_event.get('current_folder_node', '') parent_folder_id = upload_event.get('parent_folder_id', '') create_folder_flag = upload_event.get('create_folder_flag', False) @@ -155,6 +155,7 @@ def simple_upload( # noqa: C901 regular_file=regular_file, tags=tags, source_id=source_id, + upload_message=upload_message, ) # format the local path into object storage path for preupload diff --git a/app/services/file_manager/file_upload/upload_client.py b/app/services/file_manager/file_upload/upload_client.py index e189dd89..57a93ab1 100644 --- a/app/services/file_manager/file_upload/upload_client.py +++ b/app/services/file_manager/file_upload/upload_client.py @@ -224,6 +224,7 @@ def output_manifest(self, file_objects: List[FileObject], output_path: str) -> D 'parent_folder_id': self.parent_folder_id, 'current_folder_node': self.current_folder_node, 'tags': self.tags, + 'upload_message': self.upload_message, 'file_objects': {file_object.item_id: file_object.to_dict() for file_object in file_objects}, }