You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by fo...@apache.org on 2018/01/10 11:55:20 UTC

incubator-airflow git commit: [AIRFLOW-1982] Fix Executor event log formatting

Repository: incubator-airflow
Updated Branches:
  refs/heads/master e9c1ac588 -> 37a1484f7


[AIRFLOW-1982] Fix Executor event log formatting

Closes #2925 from
NielsZeilemaker/fix_email_templating


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/37a1484f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/37a1484f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/37a1484f

Branch: refs/heads/master
Commit: 37a1484f7f4e1f27524f8aacc996c18fdefbafd5
Parents: e9c1ac5
Author: niels <ni...@zeilemaker.nl>
Authored: Wed Jan 10 12:55:13 2018 +0100
Committer: Fokko Driesprong <fo...@godatadriven.com>
Committed: Wed Jan 10 12:55:13 2018 +0100

----------------------------------------------------------------------
 airflow/jobs.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/37a1484f/airflow/jobs.py
----------------------------------------------------------------------
diff --git a/airflow/jobs.py b/airflow/jobs.py
index badd4dc..6ed3f31 100644
--- a/airflow/jobs.py
+++ b/airflow/jobs.py
@@ -1414,8 +1414,8 @@ class SchedulerJob(BaseJob):
 
                 # TODO: should we fail RUNNING as well, as we do in Backfills?
                 if ti.state == State.QUEUED:
-                    msg = ("Executor reports task instance %s finished (%s) "
-                           "although the task says its %s. Was the task "
+                    msg = ("Executor reports task instance {} finished ({}) "
+                           "although the task says its {}. Was the task "
                            "killed externally?".format(ti, state, ti.state))
                     self.log.error(msg)
                     try: