Update pipeline.py

pipeline.py

@@ -200,9 +200,11 @@ async def run_async_pipeline(query: str) -> str:
     return final_refusal.strip()
 
 # Run the pipeline with the event loop
+import asyncio
+
 def run_with_chain(query: str) -> str:
-    loop = asyncio.get_event_loop()
-    return loop.run_until_complete(run_async_pipeline(query))
+    # Use asyncio.run to run the async pipeline, which ensures a fresh event loop
+    return asyncio.run(run_async_pipeline(query))
 
 # Initialize chains here
 classification_chain = get_classification_chain()