Fixed Copy/paste error

Author: holtskinner

examples/langgraph/agent.py

@@ -11,9 +11,10 @@
 )
 from langchain_core.tools import tool  # type: ignore
 from langchain_google_genai import ChatGoogleGenerativeAI
+from pydantic import BaseModel
+
 from langgraph.checkpoint.memory import MemorySaver
 from langgraph.prebuilt import create_react_agent  # type: ignore
-from pydantic import BaseModel
 
 
 logger = logging.getLogger(__name__)

src/a2a/client/client.py

@@ -26,6 +26,36 @@
 )
 
 
+async def _make_httpx_request(
+    client: httpx.AsyncClient,
+    method: str,
+    url: str,
+    json_payload: dict[str, Any] | None = None,
+    http_kwargs: dict[str, Any] | None = None,
+) -> dict[str, Any]:
+    """Makes an HTTP request and handles common errors, returning parsed JSON."""
+    try:
+        if method.upper() == 'GET':
+            response = await client.get(url, **(http_kwargs or {}))
+        elif method.upper() == 'POST':
+            response = await client.post(
+                url, json=json_payload, **(http_kwargs or {})
+            )
+        else:
+            raise ValueError(f'Unsupported HTTP method: {method}')
+
+        response.raise_for_status()
+        return response.json()
+    except httpx.HTTPStatusError as e:
+        raise A2AClientHTTPError(e.response.status_code, str(e)) from e
+    except json.JSONDecodeError as e:
+        raise A2AClientJSONError(str(e)) from e
+    except httpx.RequestError as e:
+        raise A2AClientHTTPError(
+            503, f'Network communication error: {e}'
+        ) from e
+
+
 class A2ACardResolver:
     """Agent Card resolver."""
 
@@ -42,21 +72,13 @@ def __init__(
     async def get_agent_card(
         self, http_kwargs: dict[str, Any] | None = None
     ) -> AgentCard:
-        try:
-            response = await self.httpx_client.get(
-                f'{self.base_url}/{self.agent_card_path}',
-                **(http_kwargs or {}),
-            )
-            response.raise_for_status()
-            return AgentCard.model_validate(response.json())
-        except httpx.HTTPStatusError as e:
-            raise A2AClientHTTPError(e.response.status_code, str(e)) from e
-        except json.JSONDecodeError as e:
-            raise A2AClientJSONError(str(e)) from e
-        except httpx.RequestError as e:
-            raise A2AClientHTTPError(
-                503, f'Network communication error: {e}'
-            ) from e
+        response_json = await _make_httpx_request(
+            client=self.httpx_client,
+            method='GET',
+            url=f'{self.base_url}/{self.agent_card_path}',
+            http_kwargs=http_kwargs,
+        )
+        return AgentCard.model_validate(response_json)
 
 
 class A2AClient:
@@ -152,22 +174,15 @@ async def _send_request(
 
         Args:
             rpc_request_payload: JSON RPC payload for sending the request
-            **kwargs: Additional keyword arguments to pass to the httpx client.
+            http_kwargs: Additional keyword arguments to pass to the httpx client.
         """
-        try:
-            response = await self.httpx_client.post(
-                self.url, json=rpc_request_payload, **(http_kwargs or {})
-            )
-            response.raise_for_status()
-            return response.json()
-        except httpx.HTTPStatusError as e:
-            raise A2AClientHTTPError(e.response.status_code, str(e)) from e
-        except json.JSONDecodeError as e:
-            raise A2AClientJSONError(str(e)) from e
-        except httpx.RequestError as e:
-            raise A2AClientHTTPError(
-                503, f'Network communication error: {e}'
-            ) from e
+        return await _make_httpx_request(
+            client=self.httpx_client,
+            method='POST',
+            url=self.url,
+            json_payload=rpc_request_payload,
+            http_kwargs=http_kwargs,
+        )
 
     async def get_task(
         self,