v1.0.178: classify-batch → async (202 Accepted + background thread). При 69 файлах БД задыхается.
This commit is contained in:
@@ -241,8 +241,18 @@ class Handler(BaseHTTPRequestHandler):
|
|||||||
self._json({"ok": False, "error": "batch_id required"}, 400)
|
self._json({"ok": False, "error": "batch_id required"}, 400)
|
||||||
return
|
return
|
||||||
from services.classify import classify_batch
|
from services.classify import classify_batch
|
||||||
result = classify_batch(batch_id)
|
from db import documents as db_docs
|
||||||
self._json(result)
|
import threading
|
||||||
|
|
||||||
|
# Посчитать сколько файлов — ответить сразу, классифицировать в фоне
|
||||||
|
pending = db_docs.list_pending(batch_id)
|
||||||
|
total = len(pending)
|
||||||
|
if total == 0:
|
||||||
|
self._json({"ok": False, "error": "no pending documents"}, 400)
|
||||||
|
return
|
||||||
|
|
||||||
|
threading.Thread(target=classify_batch, args=(batch_id,), daemon=True).start()
|
||||||
|
self._json({"ok": True, "total": total}, 202)
|
||||||
|
|
||||||
# ── POST /apply-groups ───────────────────────────────────────────────
|
# ── POST /apply-groups ───────────────────────────────────────────────
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user