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
On defining on_failure_callback_name and on_failure_callback_file, if the very first task (say task1) fails, context["ti"] always return the instance of last task defined in the DAG.
Eg: task1 >> task2 >> task3
If task1 fails, context["ti"] is always returning task3 instance.
If task1 succeed and task2 fails, context["ti"] returns task3 instance.
def custom_failure_function(context):
ti = context["ti"]
I think thats a bug. If it's not a bug, how can I get the failed task's instance?
The text was updated successfully, but these errors were encountered:
On defining
on_failure_callback_name
andon_failure_callback_file
, if the very first task (say task1) fails,context["ti"]
always return the instance of last task defined in the DAG.Eg: task1 >> task2 >> task3
If task1 fails,
context["ti"]
is always returning task3 instance.If task1 succeed and task2 fails,
context["ti"]
returns task3 instance.I think thats a bug. If it's not a bug, how can I get the failed task's instance?
The text was updated successfully, but these errors were encountered: