Adding changes

Author: jasonyang101

src/agentex/lib/sdk/fastacp/base/base_acp_server.py

@@ -1,5 +1,6 @@
 import asyncio
 import inspect
+from datetime import datetime
 from collections.abc import AsyncGenerator, Awaitable, Callable
 from contextlib import asynccontextmanager
 from typing import Any
@@ -97,6 +98,7 @@ async def wrapper(*args, **kwargs) -> Any:
     async def _handle_jsonrpc(self, request: Request):
         """Main JSON-RPC endpoint handler"""
         rpc_request = None
+        logger.info(f"[base_acp_server] received request: {datetime.now()}")
         try:
             data = await request.json()
             rpc_request = JSONRPCRequest(**data)

src/agentex/resources/agents.py

@@ -7,6 +7,7 @@
 from typing_extensions import Literal
 
 import httpx
+from pydantic import ValidationError
 
 from ..types import agent_rpc_params, agent_list_params, agent_rpc_by_name_params
 from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven
@@ -1073,6 +1074,8 @@ async def send_message_stream(
           except json.JSONDecodeError:
             # Skip invalid JSON lines
             continue
+          except ValidationError:
+            raise ValueError(f"Invalid SendMessageStreamResponse returned: {line}")
 
     async def send_event(
       self,