Please ignore. It is being called.
On Thu, Oct 27, 2016 at 2:39 PM, twinkle sachdeva < [email protected]> wrote: > Hi, > > I am working with a hiveToMySql transfer operation, which is not able to > connect and gives following logs: > > HiveServer2Error: Failed after retrying 3 times > > [2016-10-27 01:54:46,524] {models.py:1298} INFO - Marking task as > UP_FOR_RETRY > > > As per the code in the models.py, https://github.com/apache/ > incubator-airflow/blob/master/airflow/models.py#L1347 , it should be > calling the code for retry handler ( we are using version 1.7.1.3), but it > is not happening. > > > Here is the relevant code snippet: > > > def my_retry_handler(context): > > print "my_retry_handler called" slack_retry_notification = > SlackAPIPostOperator( task_id='Slack_Failure_Notification', > > token="XXXXXX", > > channel='@yyyyyy', > > text=":skull: - {time} - {dag} attempt has been failed > ".format(dag='Some Dag',time=datetime.now().strftime("%Y-%m-%d %H:%M:%S"), > ), > > owner='Retry Handler') > > return slack_retry_notification.execute > > > hiveToMySql = HiveToMYSQLTransfer(sql="jdbsd", hiveserver2_conn_id='hivese > rver2_default',......... > > on_retry_callback=my_retry_handler) > > > Is there something i am missing? > > > > Regards, > > Twinkle >
