from __future__importannotationsimportasynciofromsubprocessimportPIPEasyncdefmain()->None:try:asyncwithasyncio.timeout(1):process=awaitasyncio.create_subprocess_exec("/usr/bin/env","sh","-c","while true; do sleep 1; done",stdin=PIPE,stdout=PIPE,stderr=PIPE,            )try:awaitprocess.wait()exceptBaseException:process.kill()# N.B.: even though they send it SIGKILL, the user is (very briefly)# leaking an orphan process to asyncio, because they are not waiting for# the event loop to learn that the process died. if we added# while True:#     try:#         await process.wait()#     except CancelledError:#         pass#     else:#         break# (i.e. if we used structured concurrency) then the race would not# occur.raiseexceptTimeoutError:passif__name__=="__main__":asyncio.run(main())

Exception ignored in: <function BaseSubprocessTransport.__del__ at 0x7fd25db428e0>Traceback (most recent call last):    File "/usr/lib/python3.11/asyncio/base_subprocess.py", line 126, in __del__    self.close()    File "/usr/lib/python3.11/asyncio/base_subprocess.py", line 104, in close    proto.pipe.close()    File "/usr/lib/python3.11/asyncio/unix_events.py", line 566, in close    self._close(None)    File "/usr/lib/python3.11/asyncio/unix_events.py", line 590, in _close    self._loop.call_soon(self._call_connection_lost, exc)    File "/usr/lib/python3.11/asyncio/base_events.py", line 761, in call_soon    self._check_closed()    File "/usr/lib/python3.11/asyncio/base_events.py", line 519, in _check_closed    raise RuntimeError('Event loop is closed')RuntimeError: Event loop is closed

diff --git a/Lib/asyncio/base_subprocess.py b/Lib/asyncio/base_subprocess.pyindex 6dbde2b696..ba219ba39d 100644--- a/Lib/asyncio/base_subprocess.py+++ b/Lib/asyncio/base_subprocess.py@@ -123,8 +123,11 @@ def close(self):     def __del__(self, _warn=warnings.warn):         if not self._closed:-            _warn(f"unclosed transport {self!r}", ResourceWarning, source=self)-            self.close()+            if self._loop.is_closed():+                _warn("loop is closed", ResourceWarning, source=self)+            else:+                _warn(f"unclosed transport {self!r}", ResourceWarning, source=self)+                self.close()     def get_pid(self):         return self._pid

from __future__importannotationsimportasynciofromsubprocessimportPIPEasyncdefmain_leak_subprocess()->None:awaitasyncio.create_subprocess_exec("/usr/bin/env","sh","-c","while true; do sleep 1; done",stdin=PIPE,stdout=PIPE,stderr=PIPE,    )if__name__=="__main__":asyncio.run(main_leak_subprocess())

diff --git a/Lib/asyncio/base_subprocess.py b/Lib/asyncio/base_subprocess.pyindex 6dbde2b696..9c86c8444c 100644--- a/Lib/asyncio/base_subprocess.py+++ b/Lib/asyncio/base_subprocess.py@@ -123,8 +123,31 @@ def close(self):     def __del__(self, _warn=warnings.warn):         if not self._closed:-            _warn(f"unclosed transport {self!r}", ResourceWarning, source=self)-            self.close()+            if not self._loop.is_closed():+                _warn(f"unclosed transport {self!r}", ResourceWarning, source=self)+                self.close()+            else:+                _warn("loop is closed", ResourceWarning, source=self)++                # self.close() requires the event loop to be open, so we need to reach+                # into close() and its dependencies and manually do the bare-minimum+                # cleanup that they'd do if the loop was open. I.e. we do the syscalls+                # only; we can't interact with an event loop.++                # TODO: Probably need some more stuff here too so that we don't leak fd's...++                if (self._proc is not None and+                        # has the child process finished?+                        self._returncode is None and+                        # the child process has finished, but the+                        # transport hasn't been notified yet?+                        self._proc.poll() is None):++                    try:+                        self._proc.kill()+                    except (ProcessLookupError, PermissionError):+                        # the process may have already exited or may be running setuid+                        pass     def get_pid(self):         return self._pid