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: