Add some debug logging

joealcorn · Sep 3, 2015 · 000af67 · 000af67
1 parent 4c5402a
commit 000af67
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/celery_dedupe/tasks.py b/celery_dedupe/tasks.py
@@ -1,10 +1,13 @@
 import hashlib
+import logging
 import warnings
 
 from celery import Task
 from celery.result import EagerResult
 from celery.utils import uuid
 
+logger = logging.getLogger('celery_dedupe')
+
 
 class DedupeTask(Task):
     abtract = True
@@ -15,17 +18,20 @@ def apply_async(self, args=None, kwargs=None, **kw):
         task_id = kw.setdefault('task_id', uuid())
 
         if self.storage.obtain_lock(key, task_id):
+            logger.debug('Queueing %s [%s]', task_id, key)
             return super(DedupeTask, self).apply_async(args=args, kwargs=kwargs, **kw)
 
         existing_task_id = self.storage.get(key)
         if existing_task_id == task_id:
             # This should be a retry, so add it to the broker anyway
+            logger.debug('Queueing %s for retry [%s]', task_id, key)
             return super(DedupeTask, self).apply_async(args=args, kwargs=kwargs, **kw)
 
         app = self._get_app()
         if app.conf.CELERY_ALWAYS_EAGER:
             warnings.warn('Using DedupeTask in conjunction with CELERY_ALWAYS_EAGER, can not return EagerResult')
 
+        logger.debug('%s already queued, returning AsyncResult [%s]', task_id, key)
         return self.AsyncResult(existing_task_id)
 
     def on_success(self, retval, task_id, args, kwargs):