t oo created AIRFLOW-6358:
-----------------------------
Summary: print details of failed task
Key: AIRFLOW-6358
URL: https://issues.apache.org/jira/browse/AIRFLOW-6358
Project: Apache Airflow
Issue Type: Improvement
Components: logging
Affects Versions: 1.10.6
Reporter: t oo
task instance.py
BEFORE
self.state = State.FAILED
if task.retries:
self.log.info('All retries failed; marking task as FAILED')
else:
self.log.info('Marking task as FAILED.')
if task.email_on_failure and task.email:
self.email_alert(error)
AFTER
self.state = State.FAILED
if task.retries:
self.log.info('All retries failed; marking task as FAILED. dag_id=%s,
task_id=%s, execution_date=%s, start_date=%s, end_date=%s', self.dag_id,
self.task_id, self.execution_date.strftime('%Y%m%dT%H%M%S'),
self.start_date.strftime('%Y%m%dT%H%M%S'),
self.end_date.strftime('%Y%m%dT%H%M%S'))
else:
self.log.info('Marking task as FAILED. dag_id=%s, task_id=%s,
execution_date=%s, start_date=%s, end_date=%s', self.dag_id, self.task_id,
self.execution_date.strftime('%Y%m%dT%H%M%S'),
self.start_date.strftime('%Y%m%dT%H%M%S'),
self.end_date.strftime('%Y%m%dT%H%M%S'))
if task.email_on_failure and task.email:
self.email_alert(error)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
