The GitHub Actions job "Tests (AMD)" on 
airflow.git/fix/edge3-fork-deadlock-subprocess has failed.
Run started by GitHub user diogosilva30 (triggered by jscheffl).

Head commit for run:
132e2bbc5f2de6ad3e02a952b9c1535f813340e8 / Diogo Silva <[email protected]>
Unify error transport for fork and subprocess paths via temp file

Remove the multiprocessing.Queue from the fork execution path and use a
plain temp file for both fork and subprocess paths. Both paths now write
failure text to a NamedTemporaryFile (Path stored as Job.stderr_file_path);
the parent reads it after the child exits via Job.failure_details() and
pushes the content to the task log via logs_push.

Benefits over the Queue approach:
- No risk of buffer deadlock (the Queue deadlock was the original issue)
- Works identically for both fork and subprocess children
- Simpler: no IPC setup, no draining loop, no Queue import
- Error file is only created/filled on failure; task logs cover the
  success path

Also extract _make_task_temp_file() helper to avoid duplicating the
NamedTemporaryFile creation pattern across _launch_job_subprocess and
_launch_job_fork.

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

With regards,
GitHub Actions via GitBox


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

Reply via email to