legacy

Author: giancarloromeo

packages/models-library/src/models_library/api_schemas_rpc_async_jobs/async_jobs.py

@@ -23,7 +23,7 @@ class AsyncJobResult(BaseModel):
 
 class AsyncJobGet(BaseModel):
     job_id: AsyncJobId
-    job_name: AsyncJobName
+    job_name: AsyncJobName | None
 
 
 class AsyncJobAbort(BaseModel):

services/storage/src/simcore_service_storage/modules/celery/models.py

@@ -41,7 +41,7 @@ class TasksQueue(StrEnum):
 
 
 class TaskMetadata(BaseModel):
-    name: TaskName
+    name: TaskName | None
     ephemeral: bool = True
     queue: TasksQueue = TasksQueue.DEFAULT
 

services/web/server/src/simcore_service_webserver/tasks/_rest.py

@@ -85,7 +85,7 @@ async def get_async_jobs(request: web.Request) -> web.Response:
         [
             TaskGet(
                 task_id=f"{job.job_id}",
-                task_name=job.job_name,
+                task_name=job.job_name or f"{job.job_id}",
                 status_href=f"{request.url.with_path(str(request.app.router['get_async_job_status'].url_for(task_id=str(job.job_id))))}",
                 abort_href=f"{request.url.with_path(str(request.app.router['abort_async_job'].url_for(task_id=str(job.job_id))))}",
                 result_href=f"{request.url.with_path(str(request.app.router['get_async_job_result'].url_for(task_id=str(job.job_id))))}",