Re: Usage of "on_failure_callback" ?

2016-10-18 Thread Jason Chen
Hi Boris, Cool, it works fine. Thanks for the hints using sample codes. Jason On Tue, Oct 18, 2016 at 1:12 PM, Boris Tyukin wrote: > hi Jason, > > here is an example below - in task0_python_callable i did 1/0 to raise an > error and Airflow then called task0_failure_cb. I could see FAIL in

Re: Usage of "on_failure_callback" ?

2016-10-18 Thread Boris Tyukin
hi Jason, here is an example below - in task0_python_callable i did 1/0 to raise an error and Airflow then called task0_failure_cb. I could see FAIL in the task log so my task0_failure_cb was definitely invoked. The task would still have failed status if look at UI. Are you expecting a differen

Usage of "on_failure_callback" ?

2016-10-18 Thread Jason Chen
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 com