Update erich job

app/jobs/async_enrichment_job.py

@@ -4,7 +4,6 @@ from app.services.enrichment.normalize import normalize_text
 from app.services.enrichment.summary import generate_summary
 from app.services.enrichment.title_keywords import extract_title_and_keywords
 from app.services.note_store import get_note, update_note
-from app.services.enrichment.batch_pipeline import run_pipeline
 from app.models.enums import NoteStatus
 from app.utils.time import now_ts
 
@@ -22,45 +21,74 @@ async def enrich_note(note_id: str, tasks: list[str]):
     })
 
     try:
-        # 1️⃣ Normalize
+        # ---------- TEXT SOURCE ----------
+        raw_text = note.get("raw_text", "").strip()
+        text = raw_text
+
+        # ---------- 1️⃣ Normalize ----------
         if "normalize" in tasks:
-            text = await normalize_text(note.get("raw_text", ""))
-            update_note(note_id, {
-                "normalized_text": text,
-                "status": NoteStatus.normalize_done,
-                "updated_at": now_ts(),
-            })
-        else:
-            text = note.get("raw_text", "")
-
-        # 2️⃣ Title + Keywords
+            try:
+                normalized = await normalize_text(raw_text)
+                if normalized and len(normalized) > 10:
+                    text = normalized
+                    update_note(note_id, {
+                        "normalized_text": normalized,
+                        "status": NoteStatus.normalize_done,
+                        "updated_at": now_ts(),
+                    })
+            except Exception:
+                pass
+
+        # ---------- 2️⃣ Title + Keywords ----------
         if "keywords" in tasks:
-            title, keywords = await extract_title_and_keywords(text)
-            update_note(note_id, {
-                "title": title,
-                "keywords": keywords,
-                "status": NoteStatus.keywords_done,
-                "updated_at": now_ts(),
-            })
-
-        # 3️⃣ Summary
+            try:
+                title, keywords = await extract_title_and_keywords(text)
+
+                updates = {
+                    "status": NoteStatus.keywords_done,
+                    "updated_at": now_ts(),
+                }
+
+                # 🔥 FAIL-SAFE
+                if title and title.strip():
+                    updates["title"] = title.strip()
+                elif note.get("summary"):
+                    updates["title"] = note["summary"].split(".")[0][:120]
+
+                updates["keywords"] = keywords or []
+
+                update_note(note_id, updates)
+
+            except Exception:
+                pass
+
+        # ---------- 3️⃣ Summary ----------
         if "summary" in tasks:
-            summary = await generate_summary(text)
-            update_note(note_id, {
-                "summary": summary,
-                "status": NoteStatus.summary_done,
-                "updated_at": now_ts(),
-            })
-
-        # 4️⃣ Mindmap
+            try:
+                summary = await generate_summary(text)
+                if summary:
+                    update_note(note_id, {
+                        "summary": summary,
+                        "status": NoteStatus.summary_done,
+                        "updated_at": now_ts(),
+                    })
+            except Exception:
+                pass
+
+        # ---------- 4️⃣ Mindmap ----------
         if "mindmap" in tasks:
-            mindmap = await generate_mindmap(text)
-            update_note(note_id, {
-                "mindmap": mindmap,
-                "status": NoteStatus.mindmap_done,
-                "updated_at": now_ts(),
-            })
+            try:
+                mindmap = await generate_mindmap(text)
+                if mindmap:
+                    update_note(note_id, {
+                        "mindmap": mindmap,
+                        "status": NoteStatus.mindmap_done,
+                        "updated_at": now_ts(),
+                    })
+            except Exception:
+                pass
 
+        # ---------- DONE ----------
         update_note(note_id, {
             "status": NoteStatus.ready,
             "updated_at": now_ts(),