Worker: upload PDF to API after write

backend/worker/worker.py

@@ -3,6 +3,24 @@ from __future__ import annotations
 import os
 import requests
 
+def _upload_pdf_to_api(pdf_id, pdf_path, pdf_name):
+    base = (os.environ.get("PDF_TRAINER_API_BASE") or "").strip()
+    if not base:
+        print("[worker] PDF_TRAINER_API_BASE not set - skipping upload")
+        return
+    url = base.rstrip("/") + "/api/pdf/" + str(pdf_id)
+    print(f"[worker] uploading pdf_id={pdf_id} to {url}")
+    with open(pdf_path, "rb") as f:
+        r = requests.post(
+            url,
+            files={"file": (f"{pdf_id}.pdf", f, "application/pdf")},
+            data={"pdf_name": pdf_name},
+            timeout=30,
+        )
+    print(f"[worker] upload status={r.status_code}")
+    r.raise_for_status()
+
+
 PDF_TRAINER_API_BASE = (os.environ.get('PDF_TRAINER_API_BASE') or '').strip()
 import time
 import uuid
@@ -130,6 +148,7 @@ def _process_train_label(gmail: GmailClient, s: Settings, root: Path) -> None:
             pdf_bytes = gmail.download_attachment(m.msg_id, att_id)
 
             pdf_id, stored_pdf_path = _write_pipeline_pdf(root, filename, pdf_bytes)
+            _upload_pdf_to_api(pdf_id, stored_pdf_path, filename)
             trainer_link = f"{s.trainer_base_url.rstrip('/')}/?pdf_id={pdf_id}"
 
             gmail.move_message(m.msg_id, add_labels=[], remove_labels=[], mark_read=True)