attempt to propagate other errors that seem to be currently swallowed?

Author: shirley-perplexity

src/mcp/client/sse.py

@@ -126,8 +126,9 @@ async def post_writer(endpoint_url: str):
                                     )
                                     response.raise_for_status()
                                     logger.debug(f"Client message sent successfully: {response.status_code}")
-                        except Exception:
+                        except Exception as exc:
                             logger.exception("Error in post_writer")
+                            await read_stream_writer.send(exc)
                         finally:
                             await write_stream.aclose()
 

src/mcp/client/streamable_http.py

@@ -417,8 +417,9 @@ async def handle_request_async():
                     else:
                         await handle_request_async()
 
-        except Exception:
+        except Exception as exc:
             logger.exception("Error in post_writer")
+            await read_stream_writer.send(exc)
         finally:
             await read_stream_writer.aclose()
             await write_stream.aclose()