jason810496 opened a new issue, #74063:
URL: https://github.com/apache/airflow/issues/74063
A `@task.stub` task that a coordinator runs in a Lang-SDK runtime (Go, Java,
TypeScript) never runs the task callbacks declared on it in the Python Dag,
such as `on_failure_callback` and `on_success_callback`. Callbacks run only
inside the Python task runner (`_run_task_state_change_callbacks` in
`task-sdk/src/airflow/sdk/execution_time/task_runner.py`). The Lang-SDK runtime
cannot run them, and neither the supervisor nor the Execution API sends a
callback request when such a task finishes. The only exception is the
scheduler's state-mismatch path ("killed externally?"), which does send a
callback request to the Dag processor.
Proposal: when a coordinator task reaches a final state, request its task
callbacks so the Dag processor runs them from the Python Dag file, as it
already does for a task that was killed externally.
---
Drafted with Claude Code (Opus 5.5).
--
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]
