remove taskresult

giancarloromeo · giancarloromeo · commit d0774721d785 · 2025-03-07T10:49:52.000+01:00
diff --git a/services/storage/src/simcore_service_storage/api/rpc/_data_export.py b/services/storage/src/simcore_service_storage/api/rpc/_data_export.py
@@ -52,7 +52,7 @@ async def start_data_export(
         ) from err
 
     task_uuid = await get_celery_client(app).send_task(
-        "export_data",
+        "export_data_with_error",
         task_context=job_id_data.model_dump(),
         files=data_export_start.file_and_folder_ids,  # ANE: adapt here your signature
     )
diff --git a/services/storage/src/simcore_service_storage/modules/celery/models.py b/services/storage/src/simcore_service_storage/modules/celery/models.py
@@ -55,8 +55,3 @@ def _check_consistency(self) -> Self:
 class TaskError(BaseModel):
     exc_type: str
     exc_msg: str
-
-
-TaskResult: TypeAlias = Annotated[
-    TaskError | Any, Field(union_mode="left_to_right")
-]

Original file line number	Diff line number	Diff line change
`@@ -52,7 +52,7 @@ async def start_data_export(`
`52`	`52`	`) from err`
`53`	`53`
`54`	`54`	`task_uuid = await get_celery_client(app).send_task(`
`55`		`- "export_data",`
	`55`	`+ "export_data_with_error",`
`56`	`56`	`task_context=job_id_data.model_dump(),`
`57`	`57`	`files=data_export_start.file_and_folder_ids, # ANE: adapt here your signature`
`58`	`58`	`)`