We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d78503b commit 2851a87Copy full SHA for 2851a87
src/a2a/client/transports/jsonrpc.py
@@ -147,10 +147,10 @@ async def send_message_streaming(
147
context,
148
)
149
150
- modified_kwargs['timeout'] = self.httpx_client.timeout.as_dict().get(
151
- 'read', None
152
- )
153
- 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
154
155
async with aconnect_sse(
156
self.httpx_client,
0 commit comments