Update app.py

app.py

@@ -49,6 +49,7 @@ 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
@@ -159,7 +160,9 @@ def flush_memory():
 
 # ── Worker loop ───────────────────────────────────────────────────────────────
 def worker_loop():
-    print(f"✓ [{WORKER_ID}] Starting worker...")
+    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,))
     print(f"✓ [{WORKER_ID}] 2-core tokenizer pool ready")