diff --git a/src/agents/orchestrator.py b/src/agents/orchestrator.py
index 49faf71..da4d07a 100644
--- a/src/agents/orchestrator.py
+++ b/src/agents/orchestrator.py
@@ -1814,7 +1814,13 @@ class AgentOrchestrator:
                     _fimi_ids = [a.get("id") for a in new_articles_for_analysis if a.get("id")]
                     if _fimi_ids:
                         from services import fimi_matcher
+                        await _pipe_start("fimi")
                         _fimi_res = await fimi_matcher.match_article_ids(db, _fimi_ids)
+                        await _pipe_done(
+                            "fimi",
+                            count_value=_fimi_res.get("articles_with_match", 0),
+                            count_secondary=_fimi_res.get("candidates", 0),
+                        )
                         logger.info(
                             "FIMI-Abgleich Incident %d: %d Artikel, %d Kandidaten, "
                             "%d verbreiten Falschbehauptungen, %d Links",
@@ -1826,6 +1832,10 @@ class AgentOrchestrator:
                 except Exception as e:
                     logger.warning("FIMI-Abgleich fehlgeschlagen fuer Incident %d: %s",
                                    incident_id, e, exc_info=True)
+                    try:
+                        await _pipe_done("fimi", count_value=0, count_secondary=0)
+                    except Exception:
+                        pass
 
                 # --- Neueste Entwicklungen (nur Live-Monitoring / adhoc) ---
                 # Basis ist jetzt das frisch generierte Lagebild (autoritativ, thematisch sauber).