Production evaluation observability

@event:payfi.pipeline.stage_completed

(@event:payfi.requirements.schema_failure OR @event:payfi.document.schema_failure OR @event:payfi.decision.schema_failure)

(@event:payfi.requirements.degraded OR @event:payfi.document.degraded OR @event:payfi.decision.degraded OR @event:payfi.document.low_confidence_critical)

@event:payfi.pipeline.stage_completed AND @durationMs:>90000

@event:payfi.raw_document.deletion_failed

@event:payfi.raw_document.cleanup_failed

SELECT
  "stageKey",
  count(*) AS samples,
  round(
    percentile_cont(0.95) WITHIN GROUP (ORDER BY "durationMs")::numeric,
    0
  )::bigint AS p95_ms
FROM operation_processing_events
WHERE "createdAt" >= now() - interval '2 hours'
  AND "durationMs" IS NOT NULL
  AND status NOT IN ('PENDING', 'RUNNING')
GROUP BY "stageKey"
ORDER BY p95_ms DESC;

SELECT
  "createdAt",
  source,
  "stageKey",
  status,
  "durationMs",
  "documentId",
  "analysisJobId",
  "n8nWorkflowId",
  "n8nExecutionId",
  "versionMetadata"
FROM operation_processing_events
WHERE "organizationId" = 'org_example'
  AND "operationId" = 'op_example'
ORDER BY sequence, "createdAt";