Update pipeline.py

pipeline.py

@@ -200,10 +200,15 @@ def run_pipeline(query: str) -> str:
         query = sanitize_message(query)
         topic=extract_main_topic(query)
         moderation_result = moderate_text(query)
-        if not moderation_result.is_safe:
-            return "Sorry, this query contains harmful or inappropriate content."
-
-        classification = classify_query(moderation_result.original_text)
+        try:
+            if not moderation_result.is_safe:
+                return "Sorry, this query contains harmful or inappropriate content."
+        except Exception as e:
+            raise RuntimeError(f"Error in run_runpipeline check moderation: {str(e)}")
+        try:
+            classification = classify_query(moderation_result.original_text)
+        except Exception as e:
+            raise RuntimeError(f"Error in run_runpipeline check classify_query: {str(e)}")
         
         if classification == "OutOfScope":
             refusal_text = refusal_chain.run({"topic": topic})