fix deprecated

Author: giancarloromeo

services/director-v2/src/simcore_service_director_v2/api/routes/dynamic_services.py

@@ -281,7 +281,7 @@ async def service_retrieve_data_on_ports(
         response = await services_client.request(
             "POST",
             f"{service_base_url}/retrieve",
-            content=retrieve_settings.json(by_alias=True),
+            content=retrieve_settings.model_dump_json(by_alias=True),
             timeout=timeout,
         )
 

services/director-v2/tests/conftest.py

@@ -198,7 +198,7 @@ def mock_env(
 async def client(mock_env: EnvVarsDict) -> AsyncIterator[TestClient]:
     settings = AppSettings.create_from_envs()
     app = init_app(settings)
-    print("Application settings\n", settings.json(indent=2))
+    print("Application settings\n", settings.model_dump_json(indent=2))
     # NOTE: this way we ensure the events are run in the application
     # since it starts the app on a test server
     with TestClient(app, raise_server_exceptions=True) as test_client:
@@ -209,7 +209,7 @@ async def client(mock_env: EnvVarsDict) -> AsyncIterator[TestClient]:
 async def initialized_app(mock_env: EnvVarsDict) -> AsyncIterable[FastAPI]:
     settings = AppSettings.create_from_envs()
     app = init_app(settings)
-    print("Application settings\n", settings.json(indent=2))
+    print("Application settings\n", settings.model_dump_json(indent=2))
     async with LifespanManager(app):
         yield app
 

services/director-v2/tests/unit/with_dbs/test_api_route_clusters.py

@@ -311,7 +311,7 @@ async def test_create_cluster(
     response = await async_client.post(
         create_cluster_url,
         json=json.loads(
-            cluster_data.json(
+            cluster_data.model_dump_json(
                 by_alias=True,
                 exclude_unset=True,
                 encoder=create_json_encoder_wo_secrets(ClusterCreate),
@@ -355,7 +355,7 @@ async def test_update_own_cluster(
     response = await async_client.patch(
         f"/v2/clusters/15615165165165?user_id={user_1['id']}",
         json=json.loads(
-            ClusterPatch().json(
+            ClusterPatch().model_dump_json(
                 **_PATCH_EXPORT, encoder=create_json_encoder_wo_secrets(ClusterPatch)
             )
         ),
@@ -377,7 +377,7 @@ async def test_update_own_cluster(
     response = await async_client.patch(
         f"/v2/clusters/{the_cluster.id}?user_id={user_1['id']}",
         json=json.loads(
-            ClusterPatch().json(
+            ClusterPatch().model_dump_json(
                 **_PATCH_EXPORT, encoder=create_json_encoder_wo_secrets(ClusterPatch)
             )
         ),

services/director-v2/tests/unit/with_dbs/test_api_route_computations_tasks.py

@@ -69,7 +69,7 @@ def _get_app(async_client: httpx.AsyncClient) -> FastAPI:
 
     settings: AppSettings = app.state.settings
     assert settings
-    print(settings.json(indent=1))
+    print(settings.model_dump_json(indent=1))
 
     return async_client
 

services/director-v2/tests/unit/with_dbs/test_api_route_dynamic_services.py

@@ -343,7 +343,7 @@ def test_create_dynamic_services(
     response = client.post(
         "/v2/dynamic_services",
         headers=dynamic_sidecar_headers,
-        json=json.loads(post_data.json()),
+        json=json.loads(post_data.model_dump_json()),
         follow_redirects=False,
     )
     assert (
@@ -555,7 +555,7 @@ def test_delete_service_waiting_for_manual_intervention(
     response = client.post(
         "/v2/dynamic_services",
         headers=dynamic_sidecar_headers,
-        json=json.loads(post_data.json()),
+        json=json.loads(post_data.model_dump_json()),
     )
     assert (
         response.status_code == exp_status_code

services/director-v2/tests/unit/with_dbs/test_modules_comp_scheduler_dask_scheduler.py

@@ -598,7 +598,7 @@ async def _trigger_progress_event(
         ),
     )
     await cast(DaskScheduler, scheduler)._task_progress_change_handler(  # noqa: SLF001
-        event.json()
+        event.model_dump_json()
     )
 
 
@@ -1021,7 +1021,7 @@ async def test_task_progress_triggers(
         await cast(
             DaskScheduler, scheduler
         )._task_progress_change_handler(  # noqa: SLF001
-            progress_event.json()
+            progress_event.model_dump_json()
         )
         # NOTE: not sure whether it should switch to STARTED.. it would make sense
         await _assert_comp_tasks_db(

services/director-v2/tests/unit/with_dbs/test_modules_dynamic_sidecar_docker_api.py

@@ -195,7 +195,7 @@ def dynamic_sidecar_service_spec(
             f"{to_simcore_runtime_docker_label_key('service_port')}": "80",
             f"{to_simcore_runtime_docker_label_key('service_key')}": "simcore/services/dynamic/3dviewer",
             f"{to_simcore_runtime_docker_label_key('service_version')}": "2.4.5",
-            DYNAMIC_SIDECAR_SCHEDULER_DATA_LABEL: scheduler_data_from_http_request.json(),
+            DYNAMIC_SIDECAR_SCHEDULER_DATA_LABEL: scheduler_data_from_http_request.model_dump_json(),
         },
     }