Speed up queues

huridocs · Dec 13, 2024 · 84ed069 · 84ed069
1 parent 1f0294f
commit 84ed069
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/pyproject.toml b/pyproject.toml
@@ -1,6 +1,6 @@
 [project]
 name = "queue-processor"
-version = "2024.12.12.2"
+version = "2024.12.13.1"
 description = "Manage queues on Uwazi services"
 license = { file = "LICENSE" }
 authors = [{ name = "HURIDOCS" }]

diff --git a/src/check_queues.py b/src/check_queues.py
@@ -2,7 +2,7 @@
 
 from rsmq import RedisSMQ
 
-QUEUES_NAMES = ["development_ocr"]
+QUEUES_NAMES = ["development_segmentation", "development_ocr"]
 
 if __name__ == "__main__":
     for i in range(100):

diff --git a/src/queue_processor/QueueProcessor.py b/src/queue_processor/QueueProcessor.py
@@ -74,7 +74,7 @@ def start(self, process: callable, restart_condition: Callable = None):
                     break
 
                 except NoMessageInQueue:
-                    sleep(2)
+                    sleep(0.3)
                 except redis.exceptions.ConnectionError:
                     self.exists_queues = False
                     self.queue_processor_logger.error(f"Error connecting to Redis: {self.redis_host}:{self.redis_port}")