fix(workers): serve the post-conversation summary queue

Author: AnkushMalaker

backends/advanced/src/advanced_omi_backend/workers/orchestrator/worker_registry.py

@@ -170,6 +170,27 @@ def build_worker_definitions() -> List[WorkerDefinition]:
         )
     )
 
+    # 1x dedicated Summary Worker - serves ONLY the `summary` queue. The local
+    # llama.cpp deployment exposes one inference slot, so allowing all six general
+    # workers to begin summary calls merely moves waiting time inside running jobs,
+    # where RQ correctly counts it against their 30s/60s/300s execution timeouts.
+    # Keeping that wait in Redis means timeout clocks start only when model capacity
+    # is actually available.
+    workers.append(
+        WorkerDefinition(
+            name="rq-summary-worker",
+            command=[
+                "python",
+                "-m",
+                "advanced_omi_backend.workers.rq_worker_entry",
+                "summary",
+            ],
+            worker_type=WorkerType.RQ_WORKER,
+            queues=["summary"],
+            restart_on_failure=True,
+        )
+    )
+
     # Audio Persistence Workers - Single-queue workers (audio queue)
     # Multiple workers allow concurrent audio persistence for multiple sessions
     for i in range(1, 4):  # 3 audio workers

backends/advanced/tests/test_worker_registry.py

@@ -0,0 +1,11 @@
+from advanced_omi_backend.workers.orchestrator.worker_registry import (
+    build_worker_definitions,
+)
+
+
+def test_every_post_conversation_queue_has_a_worker():
+    served_queues = {
+        queue for worker in build_worker_definitions() for queue in worker.queues
+    }
+
+    assert {"transcription", "memory", "summary", "default"} <= served_queues

tests/endpoints/audio_upload_tests.robot

@@ -180,7 +180,7 @@ Audio Upload Client ID Generation Test
     [Tags]    audio-upload	queue
 
     # Upload first file with specific device name
-    ${device_name}=    Set Variable    test-upload-device
+    ${device_name}=    Set Variable    testupload
     ${conversation1}=    Upload Audio File    ${TEST_AUDIO_FILE}    device_name=${device_name}
     ${client_id1}=    Set Variable    ${conversation1}[client_id]
     ${conversation_id1}=    Set Variable    ${conversation1}[conversation_id]