File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed
services/storage/src/simcore_service_storage/api/_worker_tasks Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change 22
33from celery import Celery # type: ignore[import-untyped]
44from celery_library .task import register_task
5- from celery_library .types import register_celery_types
5+ from celery_library .types import register_celery_types , register_pydantic_types
66from models_library .api_schemas_storage .export_data_async_jobs import AccessRightError
7+ from models_library .api_schemas_storage .storage_schemas import (
8+ FileUploadCompletionBody ,
9+ FoldersBody ,
10+ )
711from servicelib .logging_utils import log_context
812
13+ from ...models import FileMetaData
914from ._files import complete_upload_file
1015from ._paths import compute_path_size , delete_paths
1116from ._simcore_s3 import deep_copy_files_from_project , export_data
1520
1621def setup_worker_tasks (app : Celery ) -> None :
1722 register_celery_types ()
23+ register_pydantic_types (FileUploadCompletionBody , FileMetaData , FoldersBody )
1824
1925 with log_context (_logger , logging .INFO , msg = "worker task registration" ):
2026 register_task (app , export_data , dont_autoretry_for = (AccessRightError ,))
You can’t perform that action at this time.
0 commit comments