fix deprecated

Author: giancarloromeo

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

@@ -129,7 +129,7 @@ async def test_publish_service_started_metrics(
         task=random.choice(tasks),  # noqa: S311
     )
     await _assert_message_received(
-        mocked_message_parser, 1, InstrumentationRabbitMessage.parse_raw
+        mocked_message_parser, 1, InstrumentationRabbitMessage.model_validate_json
     )
 
 
@@ -154,7 +154,7 @@ async def test_publish_service_stopped_metrics(
         task_final_state=random.choice(list(RunningState)),  # noqa: S311
     )
     await _assert_message_received(
-        mocked_message_parser, 1, InstrumentationRabbitMessage.parse_raw
+        mocked_message_parser, 1, InstrumentationRabbitMessage.model_validate_json
     )
 
 
@@ -207,7 +207,7 @@ async def test_publish_service_resource_tracking_started(
     )
     after_publication_time = datetime.datetime.now(datetime.timezone.utc)
     received_messages = await _assert_message_received(
-        mocked_message_parser, 1, RabbitResourceTrackingStartedMessage.parse_raw
+        mocked_message_parser, 1, RabbitResourceTrackingStartedMessage.model_validate_json
     )
     assert isinstance(received_messages[0], RabbitResourceTrackingStartedMessage)
     assert received_messages[0].service_run_id == random_service_run_id
@@ -241,7 +241,7 @@ async def test_publish_service_resource_tracking_stopped(
     )
     after_publication_time = datetime.datetime.now(datetime.timezone.utc)
     received_messages = await _assert_message_received(
-        mocked_message_parser, 1, RabbitResourceTrackingStoppedMessage.parse_raw
+        mocked_message_parser, 1, RabbitResourceTrackingStoppedMessage.model_validate_json
     )
     assert isinstance(received_messages[0], RabbitResourceTrackingStoppedMessage)
     assert received_messages[0].service_run_id == random_service_run_id
@@ -272,7 +272,7 @@ async def test_publish_service_resource_tracking_heartbeat(
     )
     after_publication_time = datetime.datetime.now(datetime.timezone.utc)
     received_messages = await _assert_message_received(
-        mocked_message_parser, 1, RabbitResourceTrackingHeartbeatMessage.parse_raw
+        mocked_message_parser, 1, RabbitResourceTrackingHeartbeatMessage.model_validate_json
     )
     assert isinstance(received_messages[0], RabbitResourceTrackingHeartbeatMessage)
     assert received_messages[0].service_run_id == random_service_run_id