Connect via SSE transport with timeout parameters.
(self)
| 237 | return await self.exit_stack.enter_async_context(stdio_client(server_params)) |
| 238 | |
| 239 | async def _connect_sse(self): |
| 240 | """Connect via SSE transport with timeout parameters.""" |
| 241 | connect_timeout = self._get_connect_timeout() |
| 242 | sse_read_timeout = self._get_sse_read_timeout() |
| 243 | |
| 244 | return await self.exit_stack.enter_async_context( |
| 245 | sse_client( |
| 246 | url=self.url, |
| 247 | headers=self.headers if self.headers else None, |
| 248 | timeout=connect_timeout, |
| 249 | sse_read_timeout=sse_read_timeout, |
| 250 | ) |
| 251 | ) |
| 252 | |
| 253 | async def _connect_streamable_http(self): |
| 254 | """Connect via Streamable HTTP transport with timeout parameters.""" |
no test coverage detected