Update app.py

app.py

@@ -49,7 +49,6 @@ def claim_shard(state):
     for name, info in state["shards"].items():
         if info["status"] == "pending":
             raw_path = Path(RAW_DIR) / name
-            print(f"  [{WORKER_ID}] Checking: {raw_path} | exists: {raw_path.exists()}")
             if raw_path.exists():
                 info["status"]     = "claimed"
                 info["worker"]     = WORKER_ID
@@ -160,11 +159,8 @@ def flush_memory():
 
 # ── Worker loop ───────────────────────────────────────────────────────────────
 def worker_loop():
-    print(f"✓ [{WORKER_ID}] worker_loop started")
-    print(f"  STATE_FILE exists: {os.path.exists(STATE_FILE)}")
-    print(f"  RAW_DIR contents: {list(Path(RAW_DIR).iterdir())[:5]}")
-    pool = mp.Pool(processes=2, initializer=init_worker, initargs=(TOK_PATH,), 
-               context=mp.get_context("spawn"))
+    print(f"✓ [{WORKER_ID}] Starting worker...")
+    pool = mp.Pool(processes=2, initializer=init_worker, initargs=(TOK_PATH,))
     print(f"✓ [{WORKER_ID}] 2-core tokenizer pool ready")
 
     try: