[
https://issues.apache.org/jira/browse/AIRFLOW-6358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jarek Potiuk updated AIRFLOW-6358:
----------------------------------
Fix Version/s: (was: 2.0.0)
1.10.8
> 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
> Assignee: t oo
> Priority: Trivial
> Fix For: 1.10.8
>
>
> 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)
