fix deprecated

Author: giancarloromeo

services/director-v2/src/simcore_service_director_v2/modules/db/repositories/comp_tasks/_utils.py

@@ -89,7 +89,7 @@ async def _get_service_details(
         node.version,
         product_name,
     )
-    obj: ServiceMetaDataPublished = ServiceMetaDataPublished.construct(
+    obj: ServiceMetaDataPublished = ServiceMetaDataPublished.model_construct(
         **service_details
     )
     return obj

services/director-v2/src/simcore_service_director_v2/modules/dynamic_sidecar/docker_compose_specs.py

@@ -239,7 +239,7 @@ def _update_container_labels(
             spec_service_key, default_limits
         )
 
-        label_keys = StandardSimcoreDockerLabels.construct(
+        label_keys = StandardSimcoreDockerLabels.model_construct(
             user_id=user_id,
             project_id=project_id,
             node_id=node_id,

services/director-v2/src/simcore_service_director_v2/modules/dynamic_sidecar/scheduler/_core/_event_create_sidecars.py

@@ -254,7 +254,7 @@ async def action(cls, app: FastAPI, scheduler_data: SchedulerData) -> None:
                 include=_DYNAMIC_SIDECAR_SERVICE_EXTENDABLE_SPECS,
             )
         )
-        rabbit_message = ProgressRabbitMessageNode.construct(
+        rabbit_message = ProgressRabbitMessageNode.model_construct(
             user_id=scheduler_data.user_id,
             project_id=scheduler_data.project_id,
             node_id=scheduler_data.node_uuid,
@@ -272,7 +272,7 @@ async def action(cls, app: FastAPI, scheduler_data: SchedulerData) -> None:
             )
         )
 
-        rabbit_message = ProgressRabbitMessageNode.construct(
+        rabbit_message = ProgressRabbitMessageNode.model_construct(
             user_id=scheduler_data.user_id,
             project_id=scheduler_data.project_id,
             node_id=scheduler_data.node_uuid,

services/director-v2/src/simcore_service_director_v2/utils/dask.py

@@ -314,7 +314,7 @@ def compute_task_labels(
         ValidationError
     """
     product_name = run_metadata.get("product_name", UNDEFINED_DOCKER_LABEL)
-    standard_simcore_labels = StandardSimcoreDockerLabels.construct(
+    standard_simcore_labels = StandardSimcoreDockerLabels.model_construct(
         user_id=user_id,
         project_id=project_id,
         node_id=node_id,

services/director-v2/src/simcore_service_director_v2/utils/rabbitmq.py

@@ -31,7 +31,7 @@ async def publish_service_started_metrics(
     simcore_user_agent: str,
     task: CompTaskAtDB,
 ) -> None:
-    message = InstrumentationRabbitMessage.construct(
+    message = InstrumentationRabbitMessage.model_construct(
         metrics="service_started",
         user_id=user_id,
         project_id=task.project_id,
@@ -53,7 +53,7 @@ async def publish_service_stopped_metrics(
     task: CompTaskAtDB,
     task_final_state: RunningState,
 ) -> None:
-    message = InstrumentationRabbitMessage.construct(
+    message = InstrumentationRabbitMessage.model_construct(
         metrics="service_stopped",
         user_id=user_id,
         project_id=task.project_id,
@@ -153,7 +153,7 @@ async def publish_service_log(
     log: str,
     log_level: LogLevelInt,
 ) -> None:
-    message = LoggerRabbitMessage.construct(
+    message = LoggerRabbitMessage.model_construct(
         user_id=user_id,
         project_id=project_id,
         node_id=node_id,
@@ -172,7 +172,7 @@ async def publish_service_progress(
     node_id: NodeID,
     progress: NonNegativeFloat,
 ) -> None:
-    message = ProgressRabbitMessageNode.construct(
+    message = ProgressRabbitMessageNode.model_construct(
         user_id=user_id,
         project_id=project_id,
         node_id=node_id,
@@ -188,7 +188,7 @@ async def publish_project_log(
     log: str,
     log_level: LogLevelInt,
 ) -> None:
-    message = LoggerRabbitMessage.construct(
+    message = LoggerRabbitMessage.model_construct(
         user_id=user_id,
         project_id=project_id,
         node_id=None,

services/director-v2/tests/unit/test_utils_dags.py

@@ -476,7 +476,7 @@ def pipeline_test_params(
                 for x in range(_MANY_NODES)
             },
             [
-                CompTaskAtDB.construct(
+                CompTaskAtDB.model_construct(
                     project_id=uuid4(),
                     node_id=f"node_{x}",
                     schema=NodeSchema(inputs={}, outputs={}),
@@ -493,7 +493,7 @@ def pipeline_test_params(
                 )
                 for x in range(_MANY_NODES)
             ],
-            PipelineDetails.construct(
+            PipelineDetails.model_construct(
                 adjacency_list={f"node_{x}": [] for x in range(_MANY_NODES)},
                 progress=1.0,
                 node_states={
@@ -527,7 +527,7 @@ def pipeline_test_params(
             },
             [
                 # NOTE: we use construct here to be able to use non uuid names to simplify test setup
-                CompTaskAtDB.construct(
+                CompTaskAtDB.model_construct(
                     project_id=uuid4(),
                     node_id="node_1",
                     schema=NodeSchema(inputs={}, outputs={}),
@@ -541,7 +541,7 @@ def pipeline_test_params(
                     modified=datetime.datetime.now(tz=datetime.timezone.utc),
                     last_heartbeat=None,
                 ),
-                CompTaskAtDB.construct(
+                CompTaskAtDB.model_construct(
                     project_id=uuid4(),
                     node_id="node_2",
                     schema=NodeSchema(inputs={}, outputs={}),
@@ -555,7 +555,7 @@ def pipeline_test_params(
                     modified=datetime.datetime.now(tz=datetime.timezone.utc),
                     last_heartbeat=None,
                 ),
-                CompTaskAtDB.construct(
+                CompTaskAtDB.model_construct(
                     project_id=uuid4(),
                     node_id="node_3",
                     schema=NodeSchema(inputs={}, outputs={}),
@@ -571,7 +571,7 @@ def pipeline_test_params(
                     progress=1.00,
                 ),
             ],
-            PipelineDetails.construct(
+            PipelineDetails.model_construct(
                 adjacency_list={
                     "node_1": ["node_2", "node_3"],
                     "node_2": ["node_3"],
@@ -597,5 +597,6 @@ async def test_compute_pipeline_details(
         pipeline_test_params.comp_tasks,
     )
     assert (
-        received_details.model_dump() == pipeline_test_params.expected_pipeline_details.model_dump()
+        received_details.model_dump()
+        == pipeline_test_params.expected_pipeline_details.model_dump()
     )

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

@@ -179,7 +179,7 @@ def mocked_catalog_service_fcts(
 ) -> Iterator[respx.MockRouter]:
     def _mocked_service_resources(request) -> httpx.Response:
         return httpx.Response(
-            200, json=jsonable_encoder(fake_service_resources, by_alias=True)
+            httpx.codes.OK, json=jsonable_encoder(fake_service_resources, by_alias=True)
         )
 
     def _mocked_services_details(