mirror of
https://github.com/hanzoai/insights.git
synced 2026-10-30 16:15:31 +00:00
zeekay
82120531a1
drop_closure exists to refuse a drop that is really a refactor: if code we keep still imports a product, deleting it is a ModuleNotFoundError waiting for the next boot. It only ever read Python, so half the dependency graph was invisible to it and five products whose TypeScript the core still imports were dropped anyway — 21 files left importing 25 specifiers that resolve to nothing, including lib/api.ts, which 760 files import, and seven lazy scene imports in productScenes.tsx. Django booted past it and the bundle did not, which is why the Python-only rule looked like it was working. The closure now reads both module systems through one table of (extensions, pattern) pairs, so a third one is a row rather than a branch. The TypeScript pattern is anchored on the import keyword rather than on the path, because jest's testPathIgnorePatterns and oxlint's ignore list quote a product path precisely because it is NOT built; matching those would hold desktop, the 4,797-file product the drop is mostly for. integrations, wizard, platform_features, visual_review and ai_gateway come back with their Django apps and workspace entries, since the closure now spares them. desktop, field_notes, ingestion and support stay dropped.
57 lines
2.1 KiB
Python
57 lines
2.1 KiB
Python
from prometheus_client import Counter, Histogram
|
|
|
|
from products.wizard.backend.facade.contracts import WizardSessionDTO
|
|
from products.wizard.backend.facade.enums import RunPhase
|
|
|
|
_KNOWN_WORKFLOWS = {"insights-integration"}
|
|
|
|
_TERMINAL_PHASES = {RunPhase.COMPLETED, RunPhase.ERROR}
|
|
|
|
_KNOWN_POLL_SOURCES = {"detector", "transport"}
|
|
|
|
|
|
def _workflow_label(workflow_id: str) -> str:
|
|
return workflow_id if workflow_id in _KNOWN_WORKFLOWS else "other"
|
|
|
|
|
|
def poll_source_label(raw_source: str | None) -> str:
|
|
return raw_source if raw_source in _KNOWN_POLL_SOURCES else "unknown"
|
|
|
|
|
|
WIZARD_SESSIONS_FINISHED_TOTAL = Counter(
|
|
"insights_wizard_sessions_finished_total",
|
|
"Wizard sessions that transitioned into a terminal phase, observed at the upsert API",
|
|
labelnames=["workflow", "outcome"],
|
|
)
|
|
|
|
WIZARD_SESSION_RUN_DURATION_SECONDS = Histogram(
|
|
"insights_wizard_session_run_duration_seconds",
|
|
"Wall-clock wizard run duration (started_at to the terminal upsert), by outcome",
|
|
labelnames=["workflow", "outcome"],
|
|
buckets=(30, 60, 120, 300, 600, 1200, 1800, 3600, float("inf")),
|
|
)
|
|
|
|
WIZARD_LATEST_SESSION_REQUESTS_TOTAL = Counter(
|
|
"insights_wizard_latest_session_requests_total",
|
|
"Poll requests against the latest-session endpoint, by caller source "
|
|
"(detector/transport/unknown) and result (hit/empty/killswitch)",
|
|
labelnames=["source", "result"],
|
|
)
|
|
|
|
WIZARD_PUBSUB_PUBLISH_TOTAL = Counter(
|
|
"insights_wizard_pubsub_publish_total",
|
|
"Redis fan-out publishes of session updates, by outcome (published/failed)",
|
|
labelnames=["outcome"],
|
|
)
|
|
|
|
|
|
def report_session_upserted(previous_run_phase: str | None, dto: WizardSessionDTO) -> None:
|
|
if dto.run_phase not in _TERMINAL_PHASES or previous_run_phase in _TERMINAL_PHASES:
|
|
return
|
|
workflow = _workflow_label(dto.workflow_id)
|
|
outcome = dto.run_phase.value
|
|
WIZARD_SESSIONS_FINISHED_TOTAL.labels(workflow=workflow, outcome=outcome).inc()
|
|
duration = (dto.updated_at - dto.started_at).total_seconds()
|
|
if duration >= 0:
|
|
WIZARD_SESSION_RUN_DURATION_SECONDS.labels(workflow=workflow, outcome=outcome).observe(duration)
|