Update app.py

app.py

@@ -368,6 +368,52 @@ with gr.Blocks() as interface:
                 print(f"❌ Failed to log submission to Google Sheets: {e}")
 
 
+        import multiprocessing
+        import time
+        
+        def run_with_timeout(func, args=(), kwargs={}, timeout=30, stop_value=None):
+            """
+            Runs func in a separate process with optional timeout.
+            If stop_value is provided and becomes True during execution, the process is killed early.
+            """
+            def wrapper(q, *args, **kwargs):
+                try:
+                    result = func(*args, **kwargs)
+                    q.put((True, result))
+                except Exception as e:
+                    q.put((False, e))
+        
+            q = multiprocessing.Queue()
+            p = multiprocessing.Process(target=wrapper, args=(q, *args), kwargs=kwargs)
+            p.start()
+        
+            start_time = time.time()
+            while p.is_alive():
+                # Timeout check
+                if timeout is not None and (time.time() - start_time) > timeout:
+                    p.terminate()
+                    p.join()
+                    print(f"⏱️ Timeout exceeded ({timeout} sec) — function killed.")
+                    return False, None
+        
+                # Stop flag check
+                if stop_value is not None and stop_value.value:
+                    p.terminate()
+                    p.join()
+                    print("🛑 Stop flag detected — function killed early.")
+                    return False, None
+        
+                time.sleep(0.1)  # avoid busy waiting
+        
+            # Process finished naturally
+            if not q.empty():
+                success, result = q.get()
+                if success:
+                    return True, result
+                else:
+                    raise result
+        
+            return False, None
         
         def threaded_batch_runner(file=None, text="", email=""):
             print("📧 EMAIL RECEIVED:", repr(email))