You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by jl...@apache.org on 2017/03/13 22:07:37 UTC
incubator-airflow git commit: [AIRFLOW-917] Fix formatting of error
message
Repository: incubator-airflow
Updated Branches:
refs/heads/master 261b65670 -> b8164cc69
[AIRFLOW-917] Fix formatting of error message
Variables were interpolated into error message
in the wrong order.
Closes #2109 from vijaykramesh/vijay/incorrect_for
mat_of_slots_available
Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/b8164cc6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/b8164cc6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/b8164cc6
Branch: refs/heads/master
Commit: b8164cc696a240b604669033dfe6e4e40c8c72f1
Parents: 261b656
Author: Vijay Ramesh <vi...@change.org>
Authored: Mon Mar 13 18:06:38 2017 -0400
Committer: Jeremiah Lowin <jl...@apache.org>
Committed: Mon Mar 13 18:06:48 2017 -0400
----------------------------------------------------------------------
airflow/ti_deps/deps/dag_ti_slots_available_dep.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/b8164cc6/airflow/ti_deps/deps/dag_ti_slots_available_dep.py
----------------------------------------------------------------------
diff --git a/airflow/ti_deps/deps/dag_ti_slots_available_dep.py b/airflow/ti_deps/deps/dag_ti_slots_available_dep.py
index af9a627..799d1cc 100644
--- a/airflow/ti_deps/deps/dag_ti_slots_available_dep.py
+++ b/airflow/ti_deps/deps/dag_ti_slots_available_dep.py
@@ -24,5 +24,5 @@ class DagTISlotsAvailableDep(BaseTIDep):
if ti.task.dag.concurrency_reached:
yield self._failing_status(
reason="The maximum number of running tasks ({0}) for this task's DAG "
- "'{1}' has been reached.".format(ti.dag_id,
- ti.task.dag.concurrency))
+ "'{1}' has been reached.".format(ti.task.dag.concurrency,
+ ti.dag_id))