Skip to content

Commit fd03fbc

Browse files
fix serialization
1 parent 2ce21df commit fd03fbc

File tree

1 file changed

+2
-3
lines changed
  • services/director-v2/src/simcore_service_director_v2/models

1 file changed

+2
-3
lines changed

services/director-v2/src/simcore_service_director_v2/models/comp_tasks.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
ByteSize,
2222
ConfigDict,
2323
Field,
24-
PlainSerializer,
2524
PositiveInt,
2625
TypeAdapter,
2726
ValidationInfo,
@@ -118,7 +117,7 @@ class NodeSchema(BaseModel):
118117

119118
class CompTaskAtDB(BaseModel):
120119
project_id: ProjectID
121-
node_id: Annotated[NodeID, PlainSerializer(str, return_type=str)]
120+
node_id: NodeID
122121
job_id: str | None = Field(default=None, description="The worker job ID")
123122
node_schema: NodeSchema = Field(..., alias="schema")
124123
inputs: InputsDict | None = Field(..., description="the inputs payload")
@@ -181,7 +180,7 @@ def _backward_compatible_null_value(cls, v: HardwareInfo | None) -> HardwareInfo
181180

182181
def to_db_model(self, **exclusion_rules) -> dict[str, Any]:
183182
comp_task_dict = self.model_dump(
184-
by_alias=True, exclude_unset=True, **exclusion_rules
183+
mode="json", by_alias=True, exclude_unset=True, **exclusion_rules
185184
)
186185
if "state" in comp_task_dict:
187186
comp_task_dict["state"] = RUNNING_STATE_TO_DB[comp_task_dict["state"]].value

0 commit comments

Comments
 (0)