Update app.py

app.py

@@ -5,6 +5,8 @@ import data_preprocess, model, pipeline
 import os
 import hashlib
 import threading
+import multiprocessing as mp
+mp.set_start_method("spawn", force=True)  # ensures workers aren't daemonic
 
 # Gradio UI
 #stop_flag = gr.State(value=False)
@@ -479,7 +481,7 @@ with gr.Blocks() as interface:
             except Exception as e:
                 print(f"⚠️ Error processing {acc}: {e}")
                 return None
-        
+        from concurrent.futures import ProcessPoolExecutor, as_completed
         def threaded_batch_runner(file=None, text="", email=""):
             print("📧 EMAIL RECEIVED:", repr(email))
             import tempfile
@@ -628,8 +630,12 @@ with gr.Blocks() as interface:
             #         )
             #         return
     
+            from multiprocessing import get_context
+
             num_workers = min(cpu_count(), 4)  # HF free tier usually has 2 CPUs
-            pool = Pool(processes=num_workers)
+            ctx = get_context("spawn")  # ensures workers are not daemonic
+            pool = ctx.Pool(processes=num_workers)
+
         
             try:
                 for result in pool.imap_unordered(