Merge branch 'master' into patch-1

.github/workflows/ci.yaml

@@ -10,7 +10,7 @@ jobs:
       strategy:
         matrix:
           os: [macos-latest, ubuntu-22.04, windows-latest]
-          python: ['3.7', '3.8', '3.9', '3.10']
+          python: ['3.8', '3.9', '3.10', '3.11', '3.12']
           include:
           - os: ubuntu-20.04
             python: '3.6'

osrf_pycommon/process_utils/execute_process_nopty.py

@@ -130,18 +130,14 @@ def yield_to_stream(data, stream):
 
 
 def _execute_process_nopty(cmd, cwd, env, shell, stderr_to_stdout=True):
-    if stderr_to_stdout:
-        p = Popen(cmd,
-                  stdin=PIPE, stdout=PIPE, stderr=STDOUT,
-                  cwd=cwd, env=env, shell=shell, close_fds=False)
-    else:
-        p = Popen(cmd,
-                  stdin=PIPE, stdout=PIPE, stderr=PIPE,
-                  cwd=cwd, env=env, shell=shell, close_fds=False)
-
-    # Left over data from read which isn't a complete line yet
-    left_overs = {p.stdout: b'', p.stderr: b''}
+    stderr = STDOUT if stderr_to_stdout else PIPE
+    with Popen(
+        cmd, stdin=PIPE, stdout=PIPE, stderr=stderr,
+        cwd=cwd, env=env, shell=shell, close_fds=False
+    ) as p:
+        # Left over data from read which isn't a complete line yet
+        left_overs = {p.stdout: b'', p.stderr: b''}
 
-    fds = list(filter(None, [p.stdout, p.stderr]))
+        fds = list(filter(None, [p.stdout, p.stderr]))
 
-    return _yield_data(p, fds, left_overs, os.linesep)
+        yield from _yield_data(p, fds, left_overs, os.linesep)

stdeb.cfg

@@ -1,6 +1,6 @@
 [DEFAULT]
 Depends3: python3-setuptools, python3-importlib-metadata
 Conflicts3: python-osrf-pycommon
-Suite3: focal jammy bullseye bookworm
+Suite3: focal jammy noble bookworm trixie
 X-Python3-Version: >= 3.8
 No-Python2:

tests/unit/test_process_utils/impl_aep_asyncio.py

@@ -10,4 +10,5 @@ async def run(cmd, **kwargs):
     transport, protocol = await async_execute_process(
         create_protocol(), cmd, **kwargs)
     retcode = await protocol.complete
+    transport.close()
     return protocol.stdout_buffer, protocol.stderr_buffer, retcode