[
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)
