Skip to content

Commit d78503b

Browse files
committed
Fix jsonrpc send streaming request by populating headers and timeout field
1 parent 5342ca4 commit d78503b

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/a2a/client/transports/jsonrpc.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,10 @@ async def send_message_streaming(
147147
context,
148148
)
149149

150-
modified_kwargs.setdefault('timeout', None)
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())
151154

152155
async with aconnect_sse(
153156
self.httpx_client,

0 commit comments

Comments
 (0)