Update more strings to uuid

Author: holtskinner

tests/client/test_base_client.py

@@ -106,7 +106,7 @@ async def test_send_message_non_streaming_agent_capability_false(
     base_client._card.capabilities.streaming = False
     mock_transport.send_message.return_value = Task(
         id='task-789',
-        context_id='ctx-101',
+        context_id='dab80cd1-224d-47cd-abd8-cc53101fb273',
         status=TaskStatus(state=TaskState.completed),
     )
 

tests/client/test_grpc_client.py

@@ -78,7 +78,7 @@ def sample_task() -> Task:
     """Provides a sample Task object."""
     return Task(
         id='task-1',
-        context_id='ctx-1',
+        context_id='e1bbdfd5-8818-4200-873f-8124135770fe',
         status=TaskStatus(state=TaskState.completed),
     )
 
@@ -88,7 +88,7 @@ def sample_message() -> Message:
     """Provides a sample Message object."""
     return Message(
         role=Role.agent,
-        message_id='msg-response',
+        message_id='a76b49b6-494b-47fb-b416-36e3f2d622da',
         parts=[Part(root=TextPart(text='Hi there'))],
     )
 

tests/server/agent_execution/test_simple_request_context_builder.py

@@ -86,8 +86,8 @@ async def test_build_basic_context_no_populate(self):
         )
 
         params = MessageSendParams(message=create_sample_message())
-        task_id = 'test_task_id_1'
-        context_id = 'test_context_id_1'
+        task_id = 'ea57b599-5bff-4f72-8376-6e47b1e3bac0'
+        context_id = '1a4bd17f-952b-4c19-9d5e-603ae0cab8cd_1'
         current_task = create_sample_task(
             task_id=task_id, context_id=context_id
         )

tests/server/apps/jsonrpc/test_jsonrpc_app.py

@@ -193,7 +193,7 @@ def mock_handler(self):
             root=SendMessageSuccessResponse(
                 id='1',
                 result=Message(
-                    message_id='test',
+                    message_id='d2c4511e-11e1-4cda-b3fd-c24cfe8a7119',
                     role=Role.agent,
                     parts=[Part(TextPart(text='response message'))],
                 ),
@@ -324,7 +324,7 @@ def side_effect(request, context: ServerCallContext):
                 root=SendMessageSuccessResponse(
                     id='1',
                     result=Message(
-                        message_id='test',
+                        message_id='d2c4511e-11e1-4cda-b3fd-c24cfe8a7119',
                         role=Role.agent,
                         parts=[Part(TextPart(text='response message'))],
                     ),

tests/server/apps/rest/test_rest_fastapi_app.py

@@ -146,15 +146,15 @@ async def test_send_message_success_message(
 ) -> None:
     expected_response = a2a_pb2.SendMessageResponse(
         msg=a2a_pb2.Message(
-            message_id='test',
+            message_id='d2c4511e-11e1-4cda-b3fd-c24cfe8a7119',
             role=a2a_pb2.Role.ROLE_AGENT,
             content=[
                 a2a_pb2.Part(text='response message'),
             ],
         ),
     )
     request_handler.on_message_send.return_value = Message(
-        message_id='test',
+        message_id='d2c4511e-11e1-4cda-b3fd-c24cfe8a7119',
         role=Role.agent,
         parts=[Part(TextPart(text='response message'))],
     )
@@ -181,12 +181,12 @@ async def test_send_message_success_task(
 ) -> None:
     expected_response = a2a_pb2.SendMessageResponse(
         task=a2a_pb2.Task(
-            id='test_task_id',
-            context_id='test_context_id',
+            id='2cc58515-03ae-4122-a9a5-560507c822aa',
+            context_id='1a4bd17f-952b-4c19-9d5e-603ae0cab8cd',
             status=a2a_pb2.TaskStatus(
                 state=a2a_pb2.TaskState.TASK_STATE_COMPLETED,
                 update=a2a_pb2.Message(
-                    message_id='test',
+                    message_id='d2c4511e-11e1-4cda-b3fd-c24cfe8a7119',
                     role=a2a_pb2.ROLE_AGENT,
                     content=[
                         a2a_pb2.Part(text='response task message'),
@@ -196,12 +196,12 @@ async def test_send_message_success_task(
         ),
     )
     request_handler.on_message_send.return_value = Task(
-        id='test_task_id',
-        context_id='test_context_id',
+        id='2cc58515-03ae-4122-a9a5-560507c822aa',
+        context_id='1a4bd17f-952b-4c19-9d5e-603ae0cab8cd',
         status=TaskStatus(
             state=TaskState.completed,
             message=Message(
-                message_id='test',
+                message_id='d2c4511e-11e1-4cda-b3fd-c24cfe8a7119',
                 role=Role.agent,
                 parts=[Part(TextPart(text='response task message'))],
             ),

tests/server/events/test_inmemory_queue_manager.py

@@ -35,14 +35,14 @@ async def test_init(self, queue_manager):
     @pytest.mark.asyncio
     async def test_add_new_queue(self, queue_manager, event_queue):
         """Test adding a new queue to the manager."""
-        task_id = 'test_task_id'
+        task_id = '1c3a35ab-e35c-49d8-a37b-7988f5a2ecb7'
         await queue_manager.add(task_id, event_queue)
         assert queue_manager._task_queue[task_id] == event_queue
 
     @pytest.mark.asyncio
     async def test_add_existing_queue(self, queue_manager, event_queue):
         """Test adding a queue with an existing task_id raises TaskQueueExists."""
-        task_id = 'test_task_id'
+        task_id = '1c3a35ab-e35c-49d8-a37b-7988f5a2ecb7'
         await queue_manager.add(task_id, event_queue)
 
         with pytest.raises(TaskQueueExists):
@@ -51,7 +51,7 @@ async def test_add_existing_queue(self, queue_manager, event_queue):
     @pytest.mark.asyncio
     async def test_get_existing_queue(self, queue_manager, event_queue):
         """Test getting an existing queue returns the queue."""
-        task_id = 'test_task_id'
+        task_id = '1c3a35ab-e35c-49d8-a37b-7988f5a2ecb7'
         await queue_manager.add(task_id, event_queue)
 
         result = await queue_manager.get(task_id)
@@ -66,7 +66,7 @@ async def test_get_nonexistent_queue(self, queue_manager):
     @pytest.mark.asyncio
     async def test_tap_existing_queue(self, queue_manager, event_queue):
         """Test tapping an existing queue returns the tapped queue."""
-        task_id = 'test_task_id'
+        task_id = '1c3a35ab-e35c-49d8-a37b-7988f5a2ecb7'
         await queue_manager.add(task_id, event_queue)
 
         result = await queue_manager.tap(task_id)
@@ -82,7 +82,7 @@ async def test_tap_nonexistent_queue(self, queue_manager):
     @pytest.mark.asyncio
     async def test_close_existing_queue(self, queue_manager, event_queue):
         """Test closing an existing queue removes it from the manager."""
-        task_id = 'test_task_id'
+        task_id = '1c3a35ab-e35c-49d8-a37b-7988f5a2ecb7'
         await queue_manager.add(task_id, event_queue)
 
         await queue_manager.close(task_id)
@@ -97,7 +97,7 @@ async def test_close_nonexistent_queue(self, queue_manager):
     @pytest.mark.asyncio
     async def test_create_or_tap_new_queue(self, queue_manager):
         """Test create_or_tap with a new task_id creates and returns a new queue."""
-        task_id = 'test_task_id'
+        task_id = '1c3a35ab-e35c-49d8-a37b-7988f5a2ecb7'
 
         result = await queue_manager.create_or_tap(task_id)
         assert isinstance(result, EventQueue)
@@ -108,7 +108,7 @@ async def test_create_or_tap_existing_queue(
         self, queue_manager, event_queue
     ):
         """Test create_or_tap with an existing task_id taps and returns the existing queue."""
-        task_id = 'test_task_id'
+        task_id = '1c3a35ab-e35c-49d8-a37b-7988f5a2ecb7'
         await queue_manager.add(task_id, event_queue)
 
         result = await queue_manager.create_or_tap(task_id)

tests/server/request_handlers/test_grpc_handler.py

@@ -70,7 +70,7 @@ async def test_send_message_success(
     )
     response_model = types.Task(
         id='task-1',
-        context_id='ctx-1',
+        context_id='e1bbdfd5-8818-4200-873f-8124135770fe',
         status=types.TaskStatus(state=types.TaskState.completed),
     )
     mock_request_handler.on_message_send.return_value = response_model
@@ -111,7 +111,7 @@ async def test_get_task_success(
     request_proto = a2a_pb2.GetTaskRequest(name='tasks/task-1')
     response_model = types.Task(
         id='task-1',
-        context_id='ctx-1',
+        context_id='e1bbdfd5-8818-4200-873f-8124135770fe',
         status=types.TaskStatus(state=types.TaskState.working),
     )
     mock_request_handler.on_get_task.return_value = response_model
@@ -170,7 +170,7 @@ async def test_send_streaming_message(
     async def mock_stream():
         yield types.Task(
             id='task-1',
-            context_id='ctx-1',
+            context_id='e1bbdfd5-8818-4200-873f-8124135770fe',
             status=types.TaskStatus(state=types.TaskState.working),
         )
 
@@ -333,7 +333,7 @@ def side_effect(request, context: ServerCallContext):
             context.activated_extensions.add('baz')
             return types.Task(
                 id='task-1',
-                context_id='ctx-1',
+                context_id='e1bbdfd5-8818-4200-873f-8124135770fe',
                 status=types.TaskStatus(state=types.TaskState.completed),
             )
 
@@ -398,7 +398,7 @@ async def side_effect(request, context: ServerCallContext):
             context.activated_extensions.add('baz')
             yield types.Task(
                 id='task-1',
-                context_id='ctx-1',
+                context_id='e1bbdfd5-8818-4200-873f-8124135770fe',
                 status=types.TaskStatus(state=types.TaskState.working),
             )
 

tests/server/request_handlers/test_jsonrpc_handler.py

@@ -104,7 +104,7 @@ async def test_on_get_task_success(self) -> None:
         )
         call_context = ServerCallContext(state={'foo': 'bar'})
         handler = JSONRPCHandler(self.mock_agent_card, request_handler)
-        task_id = 'test_task_id'
+        task_id = '1c3a35ab-e35c-49d8-a37b-7988f5a2ecb7'
         mock_task = Task(**MINIMAL_TASK)
         mock_task_store.get.return_value = mock_task
         request = GetTaskRequest(id='1', params=TaskQueryParams(id=task_id))
@@ -142,7 +142,7 @@ async def test_on_cancel_task_success(self) -> None:
             mock_agent_executor, mock_task_store
         )
         handler = JSONRPCHandler(self.mock_agent_card, request_handler)
-        task_id = 'test_task_id'
+        task_id = '1c3a35ab-e35c-49d8-a37b-7988f5a2ecb7'
         mock_task = Task(**MINIMAL_TASK)
         mock_task_store.get.return_value = mock_task
         mock_agent_executor.cancel.return_value = None
@@ -169,7 +169,7 @@ async def test_on_cancel_task_not_supported(self) -> None:
             mock_agent_executor, mock_task_store
         )
         handler = JSONRPCHandler(self.mock_agent_card, request_handler)
-        task_id = 'test_task_id'
+        task_id = '1c3a35ab-e35c-49d8-a37b-7988f5a2ecb7'
         mock_task = Task(**MINIMAL_TASK)
         mock_task_store.get.return_value = mock_task
         mock_agent_executor.cancel.return_value = None

tests/test_types.py

@@ -1534,7 +1534,7 @@ def test_subclass_enums() -> None:
 def test_get_task_push_config_params() -> None:
     """Tests successful validation of GetTaskPushNotificationConfigParams."""
     # Minimal valid data
-    params = {'id': 'task-1234'}
+    params = {'id': 'cf810732-24e2-4f81-a235-f318de16d6f7'}
     TaskIdParams.model_validate(params)
     GetTaskPushNotificationConfigParams.model_validate(params)
 
@@ -1545,7 +1545,10 @@ def test_use_get_task_push_notification_params_for_request() -> None:
         'id': 1,
         'jsonrpc': '2.0',
         'method': 'tasks/pushNotificationConfig/get',
-        'params': {'id': 'task-1234', 'pushNotificationConfigId': 'c1'},
+        'params': {
+            'id': 'cf810732-24e2-4f81-a235-f318de16d6f7',
+            'pushNotificationConfigId': 'c1',
+        },
     }
     a2a_req_get_push_req = A2ARequest.model_validate(get_push_notif_req_data)
     assert isinstance(

tests/utils/test_proto_utils.py

@@ -15,7 +15,7 @@
 def sample_message() -> types.Message:
     return types.Message(
         message_id='15957e91-63e6-40ac-8205-1d1ffb09a5b2',
-        context_id='ctx-1',
+        context_id='e1bbdfd5-8818-4200-873f-8124135770fe',
         task_id='task-1',
         role=types.Role.user,
         parts=[
@@ -35,7 +35,7 @@ def sample_message() -> types.Message:
 def sample_task(sample_message: types.Message) -> types.Task:
     return types.Task(
         id='task-1',
-        context_id='ctx-1',
+        context_id='e1bbdfd5-8818-4200-873f-8124135770fe',
         status=types.TaskStatus(
             state=types.TaskState.working, message=sample_message
         ),