[jira] [Work started] (AIRFLOW-6358) print details of failed task

["t oo (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/AIRFLOW-6358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Work on AIRFLOW-6358 started by t oo.
-------------------------------------
> 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
>
> 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)