Мониторинг пайплайна

Текущий запуск (running)

pipeline_run_id

f13c69e3-7231-42a0-8967-1f6f0494256b

trigger

timer

started_at (Москва)

21:52 01.06.2026

started_at ISO (UTC)

2026-06-01T18:52:15.496266+00:00

current_step

generate-stories

heartbeat_at ISO

2026-06-01T19:17:48.816542+00:00

Прогресс по шагам (текущая сессия)

Полный stats_snapshot (JSON):

{
  "cluster": {
    "clusters_created": 69,
    "collection_run_id": "5255fb6d-4387-41e5-b4da-a1892bd5436f",
    "embeddings_created": 93,
    "evidence_packets_total": 93,
    "skipped_existing_clusters": 0
  },
  "collect": {
    "raw_failed": 39,
    "raw_created": 132,
    "raw_collected": 93,
    "sources_total": 6,
    "sources_failed": 0,
    "skipped_existing": 4,
    "collection_run_id": "5255fb6d-4387-41e5-b4da-a1892bd5436f",
    "sources_succeeded": 6,
    "skipped_outside_window": 650
  },
  "prepare-text": {
    "packets_created": 93,
    "skipped_existing": 0,
    "skipped_empty_text": 2,
    "raw_collected_total": 95
  },
  "seed-sources": {
    "value": 0
  },
  "create-events": {
    "events_created": 45,
    "skipped_existing": 0,
    "event_drafts_total": 45,
    "skipped_without_evidence": 0
  },
  "extract-events": {
    "failed": 20,
    "rejected": 4,
    "llm_requests": 11,
    "clusters_total": 69,
    "evidence_created": 55,
    "skipped_existing": 0,
    "event_drafts_created": 45
  },
  "resolve-entities": {
    "entities_reused": 211,
    "entities_created": 32,
    "event_drafts_total": 74,
    "event_drafts_updated": 45,
    "skipped_without_names": 29
  }
}

Последний завершённый прогон (success/failed)

pipeline_run_id

ceae2849-7703-4044-b881-6c5dd8c034e7

status

success

started_at (Москва)

21:26 01.06.2026

finished_at (Москва)

21:37 01.06.2026

started_at ISO

2026-06-01T18:26:05.215617+00:00

finished_at ISO

2026-06-01T18:37:54.904766+00:00

error_step

—

Прогресс по шагам (эта фиксация сохраняется после завершения)

Полный stats_snapshot (JSON):

{
  "dry_run": false,
  "elapsed_ms": 709443,
  "llm_updates": 2,
  "groups_found": 2,
  "groups_merged": 2,
  "decisions_count": 7,
  "merges_executed": 7,
  "peak_group_size": 7,
  "stories_absorbed": 7,
  "active_stories_total": 5632,
  "blocking_pairs_total": 5383791,
  "pairs_above_threshold": 8,
  "pairs_compared_with_embeddings": 5383791
}

Отчёт: последние прогоны

До 40 записей из pipeline_runs по убыванию времени старта. Длительность — между started_at и finished_at; для текущего running — до «сейчас» по серверному UTC.

Отчёт: merge-worker прогоны

Последние прогоны с trigger=merge_worker: статус, длительность и метрики группового слияния.

runtime_settings (только чтение)