You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
I'm experiencing an issue in airflow 3.0.6 where the on_failure_callback is not executing when configured at the task level via default_args, while the on_success_callback works correctly.
Success callbacks trigger correctly after each task completion and send Slack notifications
Failure callbacks do not trigger at all when tasks fail
Both callbacks use the same function (slack_notification_callback) for Slack notifications
I specifically need task-level callbacks rather than DAG-level callbacks because with DAG-level callbacks, I cannot identify which specific task failed, making it difficult to provide meaningful failure notifications.
Is this a known issue with task-level failure callbacks in default_args? Are there any workarounds to ensure failure callbacks execute at the task level while maintaining access to task-specific information?
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
Hello,
I'm experiencing an issue in airflow 3.0.6 where the on_failure_callback is not executing when configured at the task level via default_args, while the on_success_callback works correctly.
Current DAG Configuration:
Problem:
I specifically need task-level callbacks rather than DAG-level callbacks because with DAG-level callbacks, I cannot identify which specific task failed, making it difficult to provide meaningful failure notifications.
Is this a known issue with task-level failure callbacks in default_args? Are there any workarounds to ensure failure callbacks execute at the task level while maintaining access to task-specific information?
Beta Was this translation helpful? Give feedback.
All reactions