Function get_metric_variant_stats

api/experimentation/services.py:252–283

Run the warehouse query, returning per-variant identity counts and, per metric, per-variant sufficient statistics.

(
    *,
    environment_key: str,
    feature_name: str,
    window_start: datetime,
    window_end: datetime,
    specs: Sequence[MetricSpec],
)

def get_metric_variant_stats(
    *,
    environment_key: str,
    feature_name: str,
    window_start: datetime,
    window_end: datetime,
    specs: Sequence[MetricSpec],
) -> ResultsAggregates:
    """Run the warehouse query, returning per-variant identity counts and, per
    metric, per-variant sufficient statistics."""
    builder = ResultsQueryBuilder(specs)
    params: dict[str, object] = {
        "environment_key": environment_key,
        "exposure_event": EXPOSURE_EVENT_NAME,
        "feature_name": feature_name,
        "window_start": window_start,
        "window_end": window_end,
    }
    builder.add_metric_params(params)

    rows, columns = _get_clickhouse_client().execute(
        builder.build_query(), params, with_column_types=True
    )
    exposure_counts, metric_stats = builder.decode_rows(
        rows, [name for name, _type in columns]
    )

    return ResultsAggregates(
        specs=list(specs),
        exposure_counts=exposure_counts,
        metric_stats=metric_stats,
    )


def build_results_summary(