From 9bcd2d33ed38d84ea7a8ddc4b749be96fb5fd035 Mon Sep 17 00:00:00 2001
From: Roberto Rosario <Roberto.Rosario.Gonzalez@gmail.com>
Date: Wed, 9 Mar 2011 22:50:03 -0400
Subject: [PATCH] Added debuging loging

---
 apps/ocr/tasks.py | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/apps/ocr/tasks.py b/apps/ocr/tasks.py
index 252dc0f5db..bd82e91f81 100644
--- a/apps/ocr/tasks.py
+++ b/apps/ocr/tasks.py
@@ -32,7 +32,9 @@ class DocumentQueueWatcher(PeriodicTask):
     def run(self, **kwargs):
         logger = self.get_logger(**kwargs)
         logger.info('Running queue watcher.')
+        logger.debug('Active queues: %s' % DocumentQueue.objects.filter(state=DOCUMENTQUEUE_STATE_ACTIVE))
         for document_queue in DocumentQueue.objects.filter(state=DOCUMENTQUEUE_STATE_ACTIVE):
+            logger.debug('Analysing queue: %s' % document_queue)
             current_running_queues = QueueDocument.objects.filter(state=QUEUEDOCUMENT_STATE_PROCESSING).count()
             if current_running_queues < MAX_CONCURRENT_EXECUTION:
                 try: