From d78503b336abfd7bd451b95bbd7fc746131f6841 Mon Sep 17 00:00:00 2001 From: yuyangc <892471766@qq.com> Date: Fri, 19 Sep 2025 14:52:48 -0700 Subject: [PATCH 1/6] Fix jsonrpc send streaming request by populating headers and timeout field --- src/a2a/client/transports/jsonrpc.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/src/a2a/client/transports/jsonrpc.py b/src/a2a/client/transports/jsonrpc.py index 868b3a018..da52c28f2 100644 --- a/src/a2a/client/transports/jsonrpc.py +++ b/src/a2a/client/transports/jsonrpc.py @@ -147,7 +147,10 @@ async def send_message_streaming( context, ) - modified_kwargs.setdefault('timeout', None) + modified_kwargs['timeout'] = self.httpx_client.timeout.as_dict().get( + 'read', None + ) + modified_kwargs['headers'] = dict(self.httpx_client.headers.items()) async with aconnect_sse( self.httpx_client, From 88a93ea1f04688c00eab612af24bff6121173bde Mon Sep 17 00:00:00 2001 From: yuyangc Date: Fri, 19 Sep 2025 17:32:05 -0700 Subject: [PATCH 2/6] fix header overwrite --- src/a2a/client/transports/jsonrpc.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/a2a/client/transports/jsonrpc.py b/src/a2a/client/transports/jsonrpc.py index da52c28f2..f49362327 100644 --- a/src/a2a/client/transports/jsonrpc.py +++ b/src/a2a/client/transports/jsonrpc.py @@ -147,10 +147,10 @@ async def send_message_streaming( context, ) - modified_kwargs['timeout'] = self.httpx_client.timeout.as_dict().get( - 'read', None - ) - modified_kwargs['headers'] = dict(self.httpx_client.headers.items()) + modified_kwargs.setdefault('timeout', self.httpx_client.timeout.as_dict().get('read', None)) + headers = dict(self.httpx_client.headers.items()) + headers.update(modified_kwargs.get('headers', {})) + modified_kwargs['headers'] = headers async with aconnect_sse( self.httpx_client, From 107fbdf2cdf05f6eaba895e1e6739a848e4f7cf0 Mon Sep 17 00:00:00 2001 From: yuyangc Date: Fri, 19 Sep 2025 17:46:28 -0700 Subject: [PATCH 3/6] fix format --- src/a2a/client/transports/jsonrpc.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/a2a/client/transports/jsonrpc.py b/src/a2a/client/transports/jsonrpc.py index f49362327..3dea68f3e 100644 --- a/src/a2a/client/transports/jsonrpc.py +++ b/src/a2a/client/transports/jsonrpc.py @@ -152,6 +152,8 @@ async def send_message_streaming( headers.update(modified_kwargs.get('headers', {})) modified_kwargs['headers'] = headers + + async with aconnect_sse( self.httpx_client, 'POST', From 34d273581dec933d7ff030db5957cdb60a8a5c08 Mon Sep 17 00:00:00 2001 From: yuyangc Date: Fri, 19 Sep 2025 17:55:50 -0700 Subject: [PATCH 4/6] fix format --- src/a2a/client/transports/jsonrpc.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/a2a/client/transports/jsonrpc.py b/src/a2a/client/transports/jsonrpc.py index 3dea68f3e..79a8c378b 100644 --- a/src/a2a/client/transports/jsonrpc.py +++ b/src/a2a/client/transports/jsonrpc.py @@ -147,13 +147,13 @@ async def send_message_streaming( context, ) - modified_kwargs.setdefault('timeout', self.httpx_client.timeout.as_dict().get('read', None)) + modified_kwargs.setdefault( + 'timeout', self.httpx_client.timeout.as_dict().get('read', None) + ) headers = dict(self.httpx_client.headers.items()) headers.update(modified_kwargs.get('headers', {})) modified_kwargs['headers'] = headers - - async with aconnect_sse( self.httpx_client, 'POST', From f3b2b00218998d877de578e8c03b6832efde0c81 Mon Sep 17 00:00:00 2001 From: yuyangc Date: Sat, 20 Sep 2025 11:33:15 -0700 Subject: [PATCH 5/6] fix format --- src/a2a/client/transports/jsonrpc.py | 1 + 1 file changed, 1 insertion(+) diff --git a/src/a2a/client/transports/jsonrpc.py b/src/a2a/client/transports/jsonrpc.py index 79a8c378b..bce353b38 100644 --- a/src/a2a/client/transports/jsonrpc.py +++ b/src/a2a/client/transports/jsonrpc.py @@ -152,6 +152,7 @@ async def send_message_streaming( ) headers = dict(self.httpx_client.headers.items()) headers.update(modified_kwargs.get('headers', {})) + modified_kwargs['headers'] = headers async with aconnect_sse( From cbc65a3d92751d77987c5acc1990d5348133aa6e Mon Sep 17 00:00:00 2001 From: yuyangc Date: Sat, 20 Sep 2025 11:43:45 -0700 Subject: [PATCH 6/6] fix format --- src/a2a/client/transports/jsonrpc.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/a2a/client/transports/jsonrpc.py b/src/a2a/client/transports/jsonrpc.py index bce353b38..bfba09d71 100644 --- a/src/a2a/client/transports/jsonrpc.py +++ b/src/a2a/client/transports/jsonrpc.py @@ -148,11 +148,10 @@ async def send_message_streaming( ) modified_kwargs.setdefault( - 'timeout', self.httpx_client.timeout.as_dict().get('read', None) + 'timeout', self.httpx_client.timeout.as_dict().get('read', None) ) headers = dict(self.httpx_client.headers.items()) headers.update(modified_kwargs.get('headers', {})) - modified_kwargs['headers'] = headers async with aconnect_sse(