Update pipeline.py

pipeline.py

@@ -67,7 +67,7 @@ def classify_query(query: str) -> str:
     classification = class_result.get("text", "").strip()
     return classification if classification != "OutOfScope" else "OutOfScope"
 
-# Function to moderate text using Mistral moderation API (async version)
+# Function to moderate text using Mistral moderation API (synchronous version)
 def moderate_text(query: str) -> str:
     try:
         # Use Pydantic AI to validate the text
@@ -165,8 +165,8 @@ async def merge_responses(kb_answer: str, web_answer: str) -> str:
 
 # Orchestrate the entire workflow
 async def run_async_pipeline(query: str) -> str:
-    # Moderate the query for harmful content (async)
-    moderated_query = await moderate_text(query)
+    # Moderate the query for harmful content (sync)
+    moderated_query = moderate_text(query)
     if moderated_query == "OutOfScope":
         return "Sorry, this query contains harmful or inappropriate content."