cleanup

Author: akash329d

README.md

@@ -87,13 +87,6 @@ If you haven't created a uv-managed project yet, create one:
    ```bash
    uv add "mcp[cli]"
    ```
-   
-   For optional features, you can add extras:
-   
-   ```bash
-   # For Redis support in message queue
-   uv add "mcp[redis]"
-   ```
 
 Alternatively, for projects using pip for dependencies:
 ```bash
@@ -413,7 +406,7 @@ mcp = FastMCP("My App", message_queue=redis_queue)
 To use Redis, add the Redis dependency:
 
 ```bash
-uv add redis types-redis
+uv add "mcp[redis]"
 ```
 
 ## Examples

pyproject.toml

@@ -36,8 +36,7 @@ dependencies = [
 rich = ["rich>=13.9.4"]
 cli = ["typer>=0.12.4", "python-dotenv>=1.0.0"]
 ws = ["websockets>=15.0.1"]
-redis = ["redis>=5.2.1"]
-types-redis = ["types-redis>=4.6.0.20241004"]
+redis = ["redis>=5.2.1", "types-redis>=4.6.0.20241004"]
 
 [project.scripts]
 mcp = "mcp.cli:app [cli]"

src/mcp/server/sse.py

@@ -140,11 +140,8 @@ async def sse_writer():
             async with self._message_queue.active_for_request(
                 session_id, message_callback
             ):
-                try:
-                    logger.debug("Yielding read and write streams")
-                    yield (read_stream, write_stream)
-                finally:
-                    logger.debug(f"Closing SSE connection for session {session_id}")
+                logger.debug("Yielding read and write streams")
+                yield (read_stream, write_stream)
 
     async def handle_post_message(
         self, scope: Scope, receive: Receive, send: Send