ALLM.Pipeline.PipelineMetric (allm_pipeline v0.1.0)

Copy Markdown View Source

One normalized metrics row for a pipeline run: the found → mapped → processed funnel (plus skipped/failed) for a single entity type. See the "Metric semantics" section of steering/PIPELINE_METRICS_DASHBOARD.md.

Summary

Types

t()

Functions

changeset(metric, attrs)

Types

t()

@type t() :: %ALLM.Pipeline.PipelineMetric{
  __meta__: term(),
  entity_type: String.t() | nil,
  failed: non_neg_integer(),
  found: non_neg_integer(),
  id: Ecto.UUID.t() | nil,
  inserted_at: DateTime.t() | nil,
  mapped: non_neg_integer(),
  pipeline_name: String.t() | nil,
  pipeline_run: ALLM.Pipeline.PipelineRun.t() | Ecto.Association.NotLoaded.t(),
  pipeline_run_id: Ecto.UUID.t() | nil,
  processed: non_neg_integer(),
  skipped: non_neg_integer(),
  tokens: non_neg_integer(),
  updated_at: DateTime.t() | nil
}

Functions

changeset(metric, attrs)

@spec changeset(t(), map()) :: Ecto.Changeset.t()