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: