debugging

app.py

@@ -114,20 +114,33 @@ async def process_fal_request(request_id, model_endpoint, fal_arguments, api_key
         raise
 
 def run_async_task(request_id, model_endpoint, fal_arguments, api_key):
-    """Run async task in a new event loop"""
+    """Run async task with proper event loop management"""
     print(f"[DEBUG run_async_task] Starting for request {request_id}")
-    loop = asyncio.new_event_loop()
-    asyncio.set_event_loop(loop)
     try:
-        result = loop.run_until_complete(process_fal_request(request_id, model_endpoint, fal_arguments, api_key))
+        # Use asyncio.run() which properly creates and closes a new event loop
+        # This avoids the "event loop is closed" error on subsequent requests
+        result = asyncio.run(process_fal_request(request_id, model_endpoint, fal_arguments, api_key))
         print(f"[DEBUG run_async_task] Completed with result keys: {result.keys() if result else 'None'}")
+    except RuntimeError as e:
+        # Handle case where an event loop is already running (shouldn't happen with asyncio.run)
+        if "There is no current event loop" in str(e) or "Event loop is closed" in str(e):
+            print(f"[ERROR run_async_task] Event loop error, creating new loop: {str(e)}")
+            # Fallback: create a completely new event loop
+            loop = asyncio.new_event_loop()
+            try:
+                result = loop.run_until_complete(process_fal_request(request_id, model_endpoint, fal_arguments, api_key))
+                print(f"[DEBUG run_async_task] Completed with fallback loop")
+            finally:
+                loop.close()
+        else:
+            print(f"[ERROR run_async_task] Runtime error: {str(e)}")
+            import traceback
+            traceback.print_exc()
+            raise
     except Exception as e:
         print(f"[ERROR run_async_task] Failed: {str(e)}")
         import traceback
         traceback.print_exc()
-    finally:
-        loop.close()
-        print(f"[DEBUG run_async_task] Event loop closed for request {request_id}")
 
 @app.route('/api/generate', methods=['POST'])
 def generate():