Skip to content

Commit 53187d3

Browse files
add legacy name
1 parent 0cbec0d commit 53187d3

File tree

2 files changed

+10
-3
lines changed
  • packages/models-library/src/models_library/api_schemas_rpc_async_jobs
  • services/storage/src/simcore_service_storage/modules/celery

2 files changed

+10
-3
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ class AsyncJobResult(BaseModel):
2323

2424
class AsyncJobGet(BaseModel):
2525
job_id: AsyncJobId
26-
job_name: AsyncJobName | None
26+
job_name: AsyncJobName
2727

2828

2929
class AsyncJobAbort(BaseModel):

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

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
from uuid import UUID
55

66
from models_library.progress_bar import ProgressReport
7-
from pydantic import BaseModel
7+
from pydantic import BaseModel, model_validator
88

99
TaskContext: TypeAlias = dict[str, Any]
1010
TaskID: TypeAlias = str
@@ -41,10 +41,17 @@ class TasksQueue(StrEnum):
4141

4242

4343
class TaskMetadata(BaseModel):
44-
name: TaskName | None
44+
name: TaskName
4545
ephemeral: bool = True
4646
queue: TasksQueue = TasksQueue.DEFAULT
4747

48+
@model_validator(mode="before")
49+
@classmethod
50+
def _legacy_name_if_missing(cls, data: Any) -> Any:
51+
if isinstance(data, dict) and "name" not in data:
52+
data["name"] = ""
53+
return data
54+
4855

4956
class Task(BaseModel):
5057
uuid: TaskUUID

0 commit comments

Comments
 (0)