Update pipeline.py

pipeline.py

@@ -222,7 +222,7 @@ def run_pipeline(query: str) -> str:
             final_merged = merge_responses(csv_answer, "")
             return tailor_chain.run({"response": final_merged}).strip()
         
-        refusal_text = refusal_chain.run({"topic": "this topic"})
+        refusal_text = refusal_chain.run({"topic": topic})
         return tailor_chain.run({"response": refusal_text}).strip()
     except Exception as e:
         raise RuntimeError(f"Error in run_runpipeline: {str(e)}")