External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-01-13 11:00:03 -03:30
Code Issues Packages Projects Releases Wiki Activity

celery task fail check now uses pglock

Browse Source 
* Align locking used by celery task cleaner upper with regular task manager.
* Uses pglock/advisory lock instead of abusing Instance table lock.
This commit is contained in:
Chris Meyers 2017-07-05 11:02:38 -04:00 committed by Matthew Jones
parent 7a795b8681
commit 5b9a0b504a
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
awx/main/scheduler/tasks.py
View File

@ -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)