The GitHub Actions job "Tests (AMD)" on airflow.git/backport-f72e6c9-v3-3-test 
has succeeded.
Run started by GitHub user github-actions[bot] (triggered by ashb).

Head commit for run:
c66e5121b459cd35aa68ad73529594373b7642b1 / Andrew Chang 
<[email protected]>
[v3-3-test] Fix short-read handling in task-sdk IPC framing (#69253)

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.
(cherry picked from commit f72e6c9befa7494467fbc8ceb883148dd9cb61ec)

Co-authored-by: Andrew Chang <[email protected]>

Report URL: https://github.com/apache/airflow/actions/runs/31786876947

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to