fix circular call

main.py

@@ -16,6 +16,7 @@ import queue
 import time
 from contextlib import contextmanager
 import torch
+from utils import notification_queue, log_print
 
 # Load environment variables
 load_dotenv()
@@ -34,7 +35,6 @@ log_file = os.path.join(log_dir, 'app.log')  # Add log file path
 # Global variables for model caching and initialization status
 global_models = {}
 initialization_complete = Event()
-notification_queue = queue.Queue()
 
 def ensure_directory(path):
     """Create directory and ensure full permissions with better error handling"""
@@ -77,14 +77,6 @@ logging.basicConfig(
 )
 logger = logging.getLogger(__name__)
 
-def log_print(message, level="INFO"):
-    if level == "INFO":
-        logger.info(message)
-    elif level == "ERROR":
-        logger.error(message)
-    elif level == "WARNING":
-        logger.warning(message)
-
 def initialize_resources():
     """Initialize all required resources"""
     try:
@@ -638,11 +630,9 @@ def get_or_load_model(model_name):
             raise
     return global_models.get(model_name)
 
-def wait_for_initialization(timeout=300):
-    """Wait for initialization to complete with timeout and return status"""
-    if not initialization_complete.wait(timeout):
-        log_print("Warning: Initialization timed out", "WARNING")
-        return False
+def wait_for_initialization():
+    """Wait for initialization to complete"""
+    initialization_complete.wait()
     return True
 
 # Add this to the compute_marks route before processing files
@@ -707,21 +697,14 @@ if __name__ == '__main__':
         for directory in essential_dirs:
             ensure_directory(directory)
         
-        # Configure server for long-running requests
+        # Configure server
         app.config['SEND_FILE_MAX_AGE_DEFAULT'] = 0
-        app.config['MAX_CONTENT_LENGTH'] = 50 * 1024 * 1024  # 50MB max file size
-        
-        # Add additional server configurations
-        app.config['PERMANENT_SESSION_LIFETIME'] = 3600  # 1 hour session lifetime
-        app.config['SESSION_COOKIE_SECURE'] = True
-        app.config['SESSION_COOKIE_HTTPONLY'] = True
         
-        # Start the Flask app with increased timeout
+        # Start the Flask app
         port = int(os.environ.get('PORT', 7860))
         
         log_print(f"Starting server on port {port}")
         log_print("Server configuration:")
-        log_print(f"- Max content length: {app.config['MAX_CONTENT_LENGTH'] / 1024 / 1024}MB")
         log_print(f"- Threaded: True")
         log_print(f"- Debug mode: False")
         

utils.py

@@ -0,0 +1,22 @@
+import queue
+import logging
+import sys
+
+# Create notification queue
+notification_queue = queue.Queue()
+
+# Setup logging
+logging.basicConfig(
+    level=logging.INFO,
+    format='%(asctime)s - %(levelname)s - %(message)s',
+    handlers=[logging.StreamHandler(sys.stdout)]
+)
+logger = logging.getLogger(__name__)
+
+def log_print(message, level="INFO"):
+    if level == "INFO":
+        logger.info(message)
+    elif level == "ERROR":
+        logger.error(message)
+    elif level == "WARNING":
+        logger.warning(message)