[jira] [Updated] (AIRFLOW-6387) print details of success/skipped task

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

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

t oo updated AIRFLOW-6387:
--------------------------
    Description: print success/skipped, similar to  airflow-6358  (was: 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)

 )

> print details of success/skipped task
> -------------------------------------
>
>                 Key: AIRFLOW-6387
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-6387
>             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
>
>
> print success/skipped, similar to  airflow-6358



--
This message was sent by Atlassian Jira
(v8.3.4#803005)