Update worker.py

worker.py

@@ -122,7 +122,7 @@ class RabbitMQWorker:
                 
                 logger.info("[Worker %s] Contexts: %s", thread_id, contexts)
 
-            elif pattern == "extract_topics":
+            elif pattern == "topic_extraction":
                 data = body_dict.get("data")
                 pdf_path = data.get("pdf_path") #url
                 topic_processor = MineruNoTextProcessor(gemini_api_key=os.getenv("GEMINI_API_KEY"))