The GitHub Actions job "Tests (AMD)" on airflow.git/fix-task-sdk-framing-short-read has succeeded. Run started by GitHub user Andrushika (triggered by Andrushika).
Head commit for run: 9c4841ac9b58c7e58982d68403f0b2c38855a945 / Andrew Chang <[email protected]> Fix short-read handling in task-sdk IPC framing Stream sockets are not required to return the full requested count from recv(), but the 4-byte length prefix on the supervisor↔subprocess socket was read with a single sock.recv(4). On a short read, the parsed length is garbage, which either raises msgspec.DecodeError in the subprocess or silently deadlocks the supervisor's selector reader (length_needed=0 makes the falsy payload check skip forever, so no frame is ever dispatched to handle_requests). Accumulate the header bytes on both sides, mirroring the payload accumulation that was already correct. Add regression tests using a socket that returns 2 bytes at a time to reliably reproduce the short read. Report URL: https://github.com/apache/airflow/actions/runs/28588806800 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
