rename

Author: Andrei Neagu

services/storage/src/simcore_service_storage/api/_worker_tasks/_simcore_s3.py

@@ -62,7 +62,7 @@ async def deep_copy_files_from_project(
     return body.destination
 
 
-async def data_export(
+async def export_data(
     task: Task,
     task_id: TaskID,
     *,

services/storage/src/simcore_service_storage/api/_worker_tasks/tasks.py

@@ -7,15 +7,15 @@
 from ...modules.celery._task import register_task
 from ._files import complete_upload_file
 from ._paths import compute_path_size, delete_paths
-from ._simcore_s3 import data_export, deep_copy_files_from_project
+from ._simcore_s3 import deep_copy_files_from_project, export_data
 
 _logger = logging.getLogger(__name__)
 
 
 def setup_worker_tasks(app: Celery) -> None:
     register_celery_types()
-    with log_context(_logger, logging.INFO, msg="celery task registration"):
-        register_task(app, data_export, timeout=None)
+    with log_context(_logger, logging.INFO, msg="worker task registration"):
+        register_task(app, export_data, timeout=None)
         register_task(app, compute_path_size, timeout=None)
         register_task(app, complete_upload_file, timeout=None)
         register_task(app, delete_paths, timeout=None)

services/storage/src/simcore_service_storage/api/rpc/_simcore_s3.py

@@ -8,7 +8,7 @@
 from servicelib.rabbitmq import RPCRouter
 
 from ...modules.celery import get_celery_client
-from .._worker_tasks._simcore_s3 import data_export, deep_copy_files_from_project
+from .._worker_tasks._simcore_s3 import deep_copy_files_from_project, export_data
 
 router = RPCRouter()
 
@@ -34,7 +34,7 @@ async def start_data_export(
     app: FastAPI, job_id_data: AsyncJobNameData, paths_to_export: list[S3ObjectKey]
 ) -> AsyncJobGet:
     task_uuid = await get_celery_client(app).send_task(
-        data_export.__name__,
+        export_data.__name__,
         task_context=job_id_data.model_dump(),
         user_id=job_id_data.user_id,
         paths_to_export=paths_to_export,

services/web/server/tests/unit/with_dbs/01/storage/test_storage.py

@@ -464,7 +464,7 @@ async def test_data_export(
     )
 
     _body = DataExportPost(
-        paths=[f"{faker.uuid4()}/{faker.uuid4()}/{faker.file_name()}"]
+        paths=[Path(f"{faker.uuid4()}/{faker.uuid4()}/{faker.file_name()}")]
     )
     response = await client.post(
         f"/{API_VERSION}/storage/locations/0/data-export", data=_body.model_dump_json()
@@ -671,7 +671,7 @@ async def test_get_async_job_links(
     )
 
     _body = DataExportPost(
-        paths=[f"{faker.uuid4()}/{faker.uuid4()}/{faker.file_name()}"]
+        paths=[Path(f"{faker.uuid4()}/{faker.uuid4()}/{faker.file_name()}")]
     )
     response = await client.post(
         f"/{API_VERSION}/storage/locations/0/data-export", data=_body.model_dump_json()