airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "t oo (Jira)" <j...@apache.org>
Subject [jira] [Created] (AIRFLOW-6387) print details of success/skipped task
Date Sun, 29 Dec 2019 11:03:00 GMT
t oo created AIRFLOW-6387:
-----------------------------

             Summary: 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
             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)

Mime
View raw message