Update app.py

app.py

@@ -255,9 +255,17 @@ class BackendProcessor:
 logging.basicConfig(level=logging.INFO, format='%(asctime)s - ZEROENGINE - %(message)s', force=True)
 logger = logging.getLogger(__name__)
 
-# Suppress asyncio warnings during shutdown
+# Suppress asyncio warnings during shutdown (multiple methods)
 import warnings
 warnings.filterwarnings("ignore", category=RuntimeWarning, message=".*asyncio.*")
+warnings.filterwarnings("ignore", category=UserWarning, message=".*asyncio.*")
+
+# Set environment variable to suppress asyncio warnings
+os.environ['PYTHONASYNCIODEBUG'] = '0'
+
+# Suppress asyncio event loop warnings
+import asyncio
+asyncio.get_event_loop = lambda: None  # Prevent event loop access during shutdown
 
 # --- KERNEL INITIALIZATION ---
 try:
@@ -1895,19 +1903,50 @@ if __name__ == "__main__":
         # Final garbage collection with asyncio cleanup
         logger.info("[CLEANUP] Performing final cleanup...")
         try:
+            # More aggressive asyncio cleanup
             import asyncio
-            # Close any remaining event loops
+            import sys
+            
+            # Force close all event loops
             try:
-                loops = asyncio.all_tasks()
-                logger.info(f"[CLEANUP] Found {len(loops)} asyncio tasks")
+                # Get all running loops and close them
+                if hasattr(asyncio, 'all_tasks'):
+                    tasks = asyncio.all_tasks()
+                    logger.info(f"[CLEANUP] Found {len(tasks)} asyncio tasks")
+                    
+                    # Cancel all tasks
+                    for task in tasks:
+                        if not task.done():
+                            task.cancel()
+                    
+                    # Wait for tasks to complete
+                    if tasks:
+                        asyncio.gather(*tasks, return_exceptions=True)
+                        logger.info("[CLEANUP] All tasks cancelled")
+                
+                # Close event loops
+                if hasattr(asyncio, 'get_event_loop'):
+                    try:
+                        loop = asyncio.get_event_loop()
+                        if loop and not loop.is_closed():
+                            logger.info("[CLEANUP] Closing main event loop...")
+                            loop.close()
+                            logger.info("[CLEANUP] Main event loop closed")
+                    except RuntimeError:
+                        logger.info("[CLEANUP] No event loop to close")
                 
-                loop = asyncio.get_event_loop()
-                if loop and not loop.is_closed():
-                    logger.info("[CLEANUP] Closing event loop...")
-                    loop.close()
-                    logger.info("[CLEANUP] Event loop closed")
-            except RuntimeError:
-                logger.info("[CLEANUP] No event loop to close")
+                # Try to close any remaining loops
+                if hasattr(asyncio, '_get_running_loop'):
+                    try:
+                        running_loop = asyncio._get_running_loop()
+                        if running_loop:
+                            logger.info("[CLEANUP] Closing running loop...")
+                            running_loop.close()
+                    except:
+                        pass
+                        
+            except Exception as e:
+                logger.info(f"[CLEANUP] Asyncio cleanup note: {e}")
             
             # Final GC
             logger.info("[CLEANUP] Running final garbage collection...")