Repository: incubator-airflow Updated Branches: refs/heads/master dc1bdf622 -> ab69637be
[AIRFLOW-334] Fix using undefined variable Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/cca55d79 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/cca55d79 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/cca55d79 Branch: refs/heads/master Commit: cca55d7964612f48bb64f03c2e07d03529618b83 Parents: c32452a Author: Stanislav Kudriashev <stas.kudrias...@gmail.com> Authored: Thu Jul 14 16:06:23 2016 +0300 Committer: Stanislav Kudriashev <stas.kudrias...@gmail.com> Committed: Thu Jul 14 16:06:23 2016 +0300 ---------------------------------------------------------------------- airflow/www/views.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/cca55d79/airflow/www/views.py ---------------------------------------------------------------------- diff --git a/airflow/www/views.py b/airflow/www/views.py index 17f99d3..303ec51 100644 --- a/airflow/www/views.py +++ b/airflow/www/views.py @@ -2110,14 +2110,14 @@ class TaskInstanceModelView(ModelViewOnly): def set_task_instance_state(self, ids, target_state, session=None): try: TI = models.TaskInstance - for count, id in enumerate(ids): + count = len(ids) + for id in ids: task_id, dag_id, execution_date = id.split(',') execution_date = datetime.strptime(execution_date, '%Y-%m-%d %H:%M:%S') ti = session.query(TI).filter(TI.task_id == task_id, TI.dag_id == dag_id, TI.execution_date == execution_date).one() ti.state = target_state - count += 1 session.commit() flash( "{count} task instances were set to '{target_state}'".format(**locals()))
