Merge pull request #618 from YashPandit4u/a2a-agents-on-md

A2A Unnecessary Comments removed

Author: mayoor

model-deployment/A2A_agents_on_MD/agent_a/Dockerfile

@@ -14,5 +14,4 @@ RUN uv sync
 EXPOSE 9999
 
 # Run the app
-# CMD ["python", "-m", "__main__"] 
 CMD ["uv", "run", "."]

model-deployment/A2A_agents_on_MD/agent_a/__main__.py

@@ -151,103 +151,6 @@ async def __call__(self, scope, receive, send):
                 scope["path"] = "/"
         await self.app(scope, receive, send)
 
-# Test Client Function (for standalone testing)
-async def test_client_main() -> None:
-    PUBLIC_AGENT_CARD_PATH = '/.well-known/agent.json'
-    EXTENDED_AGENT_CARD_PATH = '/agent/authenticatedExtendedCard'
-    logging.basicConfig(level=logging.INFO)
-    logger = logging.getLogger(__name__)
-
-    base_url = 'https://modeldeployment.us-ashburn-1.oci.customer-oci.com/ocid1.tenancy.oc1..aaaaaaaafwgqzxcwlkkpl5i334qpv62s375upsw2j4ufgcizfnnhjd4l55ia/agent-a/predict'
-    async with httpx.AsyncClient(auth=get_auth(), verify=False, headers={"Content-Length": "0"}) as httpx_client:
-        resolver = A2ACardResolver(
-            httpx_client=httpx_client,
-            base_url=base_url,
-        )
-        final_agent_card_to_use: AgentCard | None = None
-        try:
-            logger.info(
-                f'Attempting to fetch public agent card from: {base_url}{PUBLIC_AGENT_CARD_PATH}'
-            )
-            _public_card = (
-                await resolver.get_agent_card()
-            )
-            logger.info('Successfully fetched public agent card:')
-            logger.info(
-                _public_card.model_dump_json(indent=2, exclude_none=True)
-            )
-            final_agent_card_to_use = _public_card
-            logger.info(
-                '\nUsing PUBLIC agent card for client initialization (default).'
-            )
-            if _public_card.supportsAuthenticatedExtendedCard:
-                try:
-                    logger.info(
-                        f'\nPublic card supports authenticated extended card. Attempting to fetch from: {base_url}{EXTENDED_AGENT_CARD_PATH}'
-                    )
-                    auth_headers_dict = {
-                        'Authorization': 'Bearer dummy-token-for-extended-card'
-                    }
-                    _extended_card = await resolver.get_agent_card(
-                        relative_card_path=EXTENDED_AGENT_CARD_PATH,
-                        http_kwargs={'headers': auth_headers_dict},
-                    )
-                    logger.info(
-                        'Successfully fetched authenticated extended agent card:'
-                    )
-                    logger.info(
-                        _extended_card.model_dump_json(
-                            indent=2, exclude_none=True
-                        )
-                    )
-                    final_agent_card_to_use = (
-                        _extended_card
-                    )
-                    logger.info(
-                        '\nUsing AUTHENTICATED EXTENDED agent card for client initialization.'
-                    )
-                except Exception as e_extended:
-                    logger.warning(
-                        f'Failed to fetch extended agent card: {e_extended}. Will proceed with public card.',
-                        exc_info=True,
-                    )
-            elif (
-                _public_card
-            ):
-                logger.info(
-                    '\nPublic card does not indicate support for an extended card. Using public card.'
-                )
-        except Exception as e:
-            logger.error(
-                f'Critical error fetching public agent card: {e}', exc_info=True
-            )
-            raise RuntimeError(
-                'Failed to fetch the public agent card. Cannot continue.'
-            ) from e
-        client = A2AClient(
-            httpx_client=httpx_client, agent_card=final_agent_card_to_use
-        )
-        logger.info('A2AClient initialized.')
-        send_message_payload: dict[str, Any] = {
-            'message': {
-                'role': 'user',
-                'parts': [
-                    {'kind': 'text', 'text': 'how much is 10 USD in INR?'}
-                ],
-                'messageId': uuid4().hex,
-            },
-        }
-        request = SendMessageRequest(
-            id=str(uuid4()), params=MessageSendParams(**send_message_payload)
-        )
-        response = await client.send_message(request)
-        print(response.model_dump(mode='json', exclude_none=True))
-        streaming_request = SendStreamingMessageRequest(
-            id=str(uuid4()), params=MessageSendParams(**send_message_payload)
-        )
-        stream_response = client.send_message_streaming(streaming_request)
-        async for chunk in stream_response:
-            print(chunk.model_dump(mode='json', exclude_none=True))
 
 # Main Application
 if __name__ == '__main__':

model-deployment/A2A_agents_on_MD/agent_a/test_client.py

@@ -52,7 +52,7 @@ async def main() -> None:
     logging.basicConfig(level=logging.INFO)
     logger = logging.getLogger(__name__)
 
-    base_url = 'https://modeldeployment.us-ashburn-1.oci.customer-oci.com/ocid1.tenancy.oc1..aaaaaaaafwgqzxcwlkkpl5i334qpv62s375upsw2j4ufgcizfnnhjd4l55ia/agent-a/predict'
+    base_url = '<add your custom url mdocid url here taken from the invoke your model screen in model deployment console>'
     async with httpx.AsyncClient(auth=get_auth(), verify=False, headers={"Content-Length": "0"}) as httpx_client:
         resolver = A2ACardResolver(
             httpx_client=httpx_client,

model-deployment/A2A_agents_on_MD/agent_b/__main__.py

@@ -73,7 +73,6 @@ async def __call__(self, scope, receive, send):
         name='Mumbai Weather Agent',
         description='Just a Mumbai weather agent',
         # url='http://localhost:9998/a2a/',
-        # url = 'https://modeldeployment.us-ashburn-1.oci.customer-oci.com/ocid1.datasciencemodeldeployment.oc1.iad.amaaaaaay75uckqayzxhro3tqig45qhlv7lpeorfijnic3tw35dli6n6mbva/predict/a2a/',
         url = agent_b_url,
         version='1.0.0',
         defaultInputModes=['text'],