Flake8 fixes and URL updates

This commit is contained in:
Wayne Witzel III
2017-11-09 20:24:50 -05:00
parent 96904968d8
commit f118e27047
20 changed files with 58 additions and 94 deletions

View File

@@ -41,7 +41,8 @@ from awx.main import tasks as awx_tasks
from awx.main.utils import decrypt_field
# Celery
from celery.task.control import inspect
from awx import celery_app
from celery.app.control import Inspect
logger = logging.getLogger('awx.main.scheduler')
@@ -130,8 +131,8 @@ class TaskManager():
}
'''
def get_active_tasks(self):
inspector = inspect()
if not hasattr(settings, 'IGNORE_CELERY_INSPECTOR'):
inspector = Inspect(app=celery_app)
active_task_queues = inspector.active()
else:
logger.warn("Ignoring celery task inspector")