fix processor queue names (#74)

meedan · Feb 28, 2024 · 3988bbd · 3988bbd
1 parent 78a93b0
commit 3988bbd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/queue/processor.py b/lib/queue/processor.py
@@ -13,7 +13,7 @@ def create(cls, model_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 = Queue.get_input_queue_name(model_name)
+        input_queue_name = Queue.get_output_queue_name(model_name)
         logger.info(f"Starting queue with: ('{input_queue_name}', {batch_size})")
         return QueueProcessor(input_queue_name, batch_size)