keith991001 opened a new pull request, #73380: URL: https://github.com/apache/airflow/pull/73380
Reviewed by @keith991001: this change addresses the callback-specific fork+exec gap described in #73143. > Task callbacks used a closure as their subprocess target, so they could not > opt into `WatchedSubprocess`'s fork+exec path and remained exposed to locks > inherited from supervisor threads. > > This change: > > - adds an importable callback child entry point and sends startup data over > the existing supervisor socket; > - applies `execute_tasks_new_python_interpreter` to callback subprocesses; > - adds a real fork+exec callback regression test and focused unit coverage; > - updates the configuration documentation and the existing significant > newsfragment. > > Tests: > > - `uv run --no-sync --project task-sdk pytest task-sdk/tests/task_sdk/execution_time/test_callback_supervisor.py -q` > - `uv run --no-sync prek run mypy-task-sdk --all-files` > - Ruff formatting and lint checks > - Applicable pre-commit and manual hooks > > closes: #73143 --- ##### Was generative AI tooling used to co-author this PR? - [X] Yes — Codex (GPT-5) Generated-by: Codex (GPT-5) following [the guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#gen-ai-assisted-contributions) --- Drafted-by: Codex (GPT-5); reviewed by @keith991001 before posting -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
