fix: ensure tasks are cancelled on shutdown

src/deno_sandbox/rpc.py

@@ -145,7 +145,11 @@ async def _listener(self) -> None:
                             del self._pending_processes[stream_id]
 
         except ConnectionClosed:
-            pass
+            # Cancel all pending requests when connection closes
+            for future in self._pending_requests.values():
+                if not future.done():
+                    future.cancel()
+            self._pending_requests.clear()
         except Exception as e:
             for future in self._pending_requests.values():
                 if not future.done():

src/deno_sandbox/wrappers.py

@@ -234,7 +234,7 @@ def __init__(
         self.returncode = None
         self._rpc = rpc
         self._stdout_task = _stdout_task
-        self._stderr_task: Optional[asyncio.Task] = None
+        self._stderr_task = _stderr_task
 
     @classmethod
     async def create(
@@ -253,14 +253,21 @@ async def wait(self) -> ChildProcessStatus:
         )
 
     async def kill(self) -> None:
-        """Kill the process."""
+        """Kill the process and cancel all associated tasks."""
 
         try:
             await self._rpc.call("processKill", {"pid": self.pid})
         except ProcessAlreadyExited:
             # Process already exited
             pass
 
+        # Cancel all associated tasks
+        self._wait_task.cancel()
+        if self._stdout_task is not None:
+            self._stdout_task.cancel()
+        if self._stderr_task is not None:
+            self._stderr_task.cancel()
+
     async def __aenter__(self):
         return self
 
@@ -397,6 +404,12 @@ async def create(
         )
         return p
 
+    async def kill(self) -> None:
+        """Kill the process and cancel all associated tasks."""
+        if self._listening_task is not None:
+            self._listening_task.cancel()
+        await super().kill()
+
     async def wait_http_ready(self) -> bool:
         """Whether the Deno process is ready to accept HTTP requests."""