From 07ed7e640e2a12a4d9000aba535f637ea1442010 Mon Sep 17 00:00:00 2001 From: Maxime Date: Tue, 23 Jun 2015 16:25:41 +0000 Subject: [PATCH] Fixing queue prioritization --- airflow/jobs.py | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/airflow/jobs.py b/airflow/jobs.py index d2649c6b43..30fca89196 100644 --- a/airflow/jobs.py +++ b/airflow/jobs.py @@ -283,11 +283,9 @@ class SchedulerJob(BaseJob): logging.debug('Triggering retry: ' + str(ti)) executor.queue_task_instance(ti) elif ti.state == State.QUEUED: - # If task instance if up for retry, make sure - if ti.is_runnable(): - logging.debug( - 'Starting previously queued : ' + str(ti)) - executor.queue_task_instance(ti) + # If was queued we skipped so that in gets prioritized + # in self.prioritize_queued + continue else: # Trying to run the next schedule next_schedule = (