CV2-3435 add processor queue prefix

meedan · Oct 11, 2023 · c93e50a · c93e50a
1 parent 62fa98e
commit c93e50a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/queue/processor.py b/lib/queue/processor.py
@@ -14,7 +14,8 @@ def create(cls, input_queue_name: str = None, batch_size: int = 10):
         Instantiate a queue. Must pass input_queue_name, output_queue_name, and batch_size.
         Pulls settings and then inits instance.
         """
-        input_queue_name = get_setting(input_queue_name, "MODEL_NAME").replace(".", "__")
+        queue_prefix = get_setting("", "QUEUE_PREFIX").replace(".", "__")
+        input_queue_name = queue_prefix+get_setting(input_queue_name, "MODEL_NAME").replace(".", "__")
         logger.info(f"Starting queue with: ('{input_queue_name}', {batch_size})")
         return QueueProcessor(input_queue_name, batch_size)