Hi airflow team,
Is there any sample code to use "on_failure_callback" ?
I tried to use that as a callback to "post-process" when a task fails.
However, I cannot make it work.
The definition of my task is as below (just one task in my dag).
It invokes "task0_python_callable" which executes a command-line script and
it could drops exception. It in turns making task0 failed.
In that case, I am thinking it should trigger the "on_failure_callback"
function "task0_failure_cb", but it does not happen.
Any suggestion?
Thanks.
Jason
=========
task0 = PythonOperator(
task_id='task0',
python_callable=task0_python_callable,
on_failure_callback=task0_failure_cb,
dag=dag)
