test

Author: felixweinberger

src/mcp/client/stdio/win32.py

@@ -76,20 +76,39 @@ async def __aexit__(
         exc_tb: object | None,
     ) -> None:
         """Terminate and wait on process exit inside a thread."""
-        self.popen.terminate()
-        await to_thread.run_sync(self.popen.wait)
+        try:
+            self.popen.terminate()
+            await to_thread.run_sync(self.popen.wait)
+        except Exception:
+            pass
 
         # Close the file handles to prevent ResourceWarning
+        # Handle already-closed streams gracefully
         if self.stdin:
-            await self.stdin.aclose()
+            try:
+                await self.stdin.aclose()
+            except Exception:
+                pass  # Already closed
         if self.stdout:
-            await self.stdout.aclose()
+            try:
+                await self.stdout.aclose()
+            except Exception:
+                pass  # Already closed
         if self.stdin_raw:
-            self.stdin_raw.close()
+            try:
+                self.stdin_raw.close()
+            except Exception:
+                pass  # Already closed
         if self.stdout_raw:
-            self.stdout_raw.close()
+            try:
+                self.stdout_raw.close()
+            except Exception:
+                pass  # Already closed
         if self.stderr:
-            self.stderr.close()
+            try:
+                self.stderr.close()
+            except Exception:
+                pass  # Already closed
 
     async def wait(self):
         """Async wait for process completion."""