using not deprecated forms

Author: Andrei Neagu

services/dynamic-scheduler/src/simcore_service_dynamic_scheduler/services/service_tracker/_api.py

@@ -150,7 +150,7 @@ async def set_if_status_changed_for_service(
     model.scheduled_to_run = False
 
     # check if model changed
-    json_status = status.json()
+    json_status = status.model_dump_json()
     if model.service_status != json_status:
         model.service_status = json_status
         model.current_state = _get_current_scheduler_service_state(

services/dynamic-scheduler/tests/unit/api_rest/test_api_rest__meta.py

@@ -9,4 +9,4 @@
 async def test_health(client: AsyncClient):
     response = await client.get(f"/{API_VTAG}/meta")
     assert response.status_code == status.HTTP_200_OK
-    assert Meta.parse_raw(response.text)
+    assert Meta.model_validate_json(response.text)

services/dynamic-scheduler/tests/unit/api_rpc/test_api_rpc__services.py

@@ -91,7 +91,9 @@ def mock_director_v0_service_state(
     ) as mock:
         mock.get(f"/fake-status/{node_id_legacy}").respond(
             status.HTTP_200_OK,
-            text=json.dumps(jsonable_encoder({"data": service_status_legacy.dict()})),
+            text=json.dumps(
+                jsonable_encoder({"data": service_status_legacy.model_dump()})
+            ),
         )
 
         # service was not found response
@@ -114,7 +116,7 @@ def mock_director_v2_service_state(
         assert_all_mocked=True,  # IMPORTANT: KEEP always True!
     ) as mock:
         mock.get(f"/dynamic_services/{node_id_new_style}").respond(
-            status.HTTP_200_OK, text=service_status_new_style.json()
+            status.HTTP_200_OK, text=service_status_new_style.model_dump_json()
         )
 
         # emulate redirect response to director-v0
@@ -199,7 +201,9 @@ def mock_director_v0_service_run(
     ) as mock:
         mock.post("/fake-service-run").respond(
             status.HTTP_201_CREATED,
-            text=json.dumps(jsonable_encoder({"data": service_status_legacy.dict()})),
+            text=json.dumps(
+                jsonable_encoder({"data": service_status_legacy.model_dump()})
+            ),
         )
 
         yield None
@@ -226,7 +230,7 @@ def mock_director_v2_service_run(
         else:
             request.respond(
                 status.HTTP_201_CREATED,
-                text=service_status_new_style.json(),
+                text=service_status_new_style.model_dump_json(),
             )
         yield None
 

services/dynamic-scheduler/tests/unit/service_tracker/test__api.py

@@ -151,7 +151,7 @@ async def test_set_if_status_changed(
     model = await get_tracked_service(app, node_id)
     assert model
 
-    assert model.service_status == status.json()
+    assert model.service_status == status.model_dump_json()
 
 
 async def test_set_service_status_task_uid(

services/dynamic-scheduler/tests/unit/status_monitor/test_services_status_monitor__monitor.py

@@ -221,10 +221,12 @@ def _side_effect_node_status_response(request: Request) -> Response:
         if isinstance(service_status, NodeGet):
             return Response(
                 status.HTTP_200_OK,
-                text=json.dumps(jsonable_encoder({"data": service_status.dict()})),
+                text=json.dumps(
+                    jsonable_encoder({"data": service_status.model_dump()})
+                ),
             )
         if isinstance(service_status, DynamicServiceGet):
-            return Response(status.HTTP_200_OK, text=service_status.json())
+            return Response(status.HTTP_200_OK, text=service_status.model_dump_json())
         if isinstance(service_status, NodeGetIdle):
             return Response(status.HTTP_404_NOT_FOUND)