Update pipeline.py

pipeline.py

@@ -182,6 +182,19 @@ def build_rag_chain(llm_model: LiteLLMModel, vectorstore: FAISS) -> RetrievalQA:
     except Exception as e:
         raise RuntimeError(f"Error building RAG chain: {str(e)}")
 
+
+def sanitize_message(message: Any) -> str:
+    """Sanitize message input to ensure it's a valid string."""
+    try:
+        if hasattr(message, 'content'):
+            return str(message.content)
+        if isinstance(message, (list, dict)):
+            return str(message)
+        return str(message)
+    except Exception as e:
+        raise RuntimeError(f"Error in sanitize function: {str(e)}")
+        
+    
 def run_pipeline(query: str) -> str:
     try:
         query = sanitize_message(query)