From 5b9a0b504aa7cb62eb8dc3d73411eb62332abc99 Mon Sep 17 00:00:00 2001 From: Chris Meyers Date: Wed, 5 Jul 2017 11:02:38 -0400 Subject: [PATCH] celery task fail check now uses pglock * Align locking used by celery task cleaner upper with regular task manager. * Uses pglock/advisory lock instead of abusing Instance table lock. --- awx/main/scheduler/tasks.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/awx/main/scheduler/tasks.py b/awx/main/scheduler/tasks.py index 5ad5bff76a..9d51d65149 100644 --- a/awx/main/scheduler/tasks.py +++ b/awx/main/scheduler/tasks.py @@ -15,7 +15,6 @@ from celery import task from awx.main.scheduler import TaskManager from django.core.cache import cache - logger = logging.getLogger('awx.main.scheduler') # TODO: move logic to UnifiedJob model and use bind=True feature of celery. @@ -59,3 +58,4 @@ def run_fail_inconsistent_running_jobs(): all_running_sorted_tasks = scheduler.get_running_tasks() scheduler.process_celery_tasks(celery_task_start_time, active_tasks, all_running_sorted_tasks) +