Additional Logging for task queue operation

This commit is contained in:
Eric Fischer
2016-11-28 17:10:33 -05:00
parent 6cdb417019
commit f69b2c41cb

View File

@@ -5,6 +5,9 @@ For more, see http://celery.readthedocs.io/en/latest/userguide/routing.html#rout
"""
from abc import ABCMeta, abstractproperty
from django.conf import settings
import logging
log = logging.getLogger(__name__)
class AlternateEnvironmentRouter(object):
@@ -30,6 +33,13 @@ class AlternateEnvironmentRouter(object):
If None is returned from this method, default routing logic is used.
"""
alternate_env = self.alternate_env_tasks.get(task, None)
if 'update_course_in_cache' in task:
log.info("TNL-5408: task={task}, args={args}, alternate_env={alt_env}, queues={queues}".format(
task=task,
args=args,
alt_env=alternate_env,
queues=getattr(settings, 'CELERY_QUEUES', []).keys()
))
if alternate_env:
return self.ensure_queue_env(alternate_env)
return None