Worker: wait for a node process's exit status before telling a signal from a failure

2026-11-01 10:59:35 +01:00
parent 7a7315043d
commit 8f4c7d8ff1
1 changed files with 4 additions and 0 deletions
@@ -304,6 +304,10 @@ class Agent:
            while True:
                line = await loop.run_in_executor(None, worker.read_line)
                if not line:
+                    # The pipe closes a moment before the exit status is
+                    # there to read, and a signal is only told by the status.
+                    with contextlib.suppress(subprocess.TimeoutExpired):
+                        await loop.run_in_executor(None, worker.proc.wait, 1)
                    await socket.send(
                        json.dumps(
                            {