You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "t oo (Jira)" <ji...@apache.org> on 2019/12/29 11:03:00 UTC
[jira] [Created] (AIRFLOW-6387) print details of success/skipped
task
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)