kaxil commented on PR #60522: URL: https://github.com/apache/airflow/pull/60522#issuecomment-3749957117
Closing this — see my comment on #60517 for the full explanation. TL;DR: `TaskDeferralTimeout` and `AirflowTaskTimeout` represent different things. `on_kill()` is meant for when the task process is actively running and needs to be killed. When a deferral timeout occurs, the task process isn't running — it's deferred. Calling `on_kill()` in that context doesn't make sense. If the EMR operator needs cleanup on deferral timeout, that logic should be added to the operator itself (e.g., in the resume callback or a custom `resume_execution`). -- 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]
