Update app.py

app.py

@@ -287,7 +287,14 @@ async def ocr_pdf(request: Request):
                 page_text = _ocr_page_via_siliconflow(local_path, i)
                 if page_text:
                     full_text += page_text + "\n\n"
-                _ocr_tasks[t_id]["progress"] = int(((i + 1) / total_pages) * 100)
+                pct = int(((i + 1) / total_pages) * 100)
+                _ocr_tasks[t_id]["progress"] = pct
+                # 每页完成后推送进度到 Worker（推模式替代拉模式）
+                if cb_url and (i % max(1, total_pages // 10) == 0 or i == total_pages - 1):
+                    try:
+                        requests.post(cb_url, json={"ok": True, "task_id": t_id, "status": "processing", "progress": pct}, timeout=10)
+                    except Exception:
+                        pass
 
             try:
                 local_path.unlink()
@@ -1415,5 +1422,4 @@ async def skill_view(request: Request):
                     return JSONResponse({"name": s["name"], "content": r.text[:2000]})
             except Exception:
                 pass
-    return JSONResponse({"error": "not found"}, status_code=404)
-    
+    return JSONResponse({"error": "not found"}, status_code=404)