Skip to content

climate_ref.results._stats #

Shared execution-statistics mapping for the results read layer.

rows_to_execution_stats(rows) #

Map raw select_execution_statistics rows to detached ExecutionStats DTOs.

Both ExecutionsReader.statistics and DiagnosticsReader.stats delegate here so the row-to-DTO mapping is defined exactly once.

Source code in packages/climate-ref/src/climate_ref/results/_stats.py 
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
def rows_to_execution_stats(rows: Iterable[Any]) -> "tuple[ExecutionStats, ...]":
    """
    Map raw ``select_execution_statistics`` rows to detached ``ExecutionStats`` DTOs.

    Both [ExecutionsReader.statistics][climate_ref.results.executions.ExecutionsReader.statistics]
    and [DiagnosticsReader.stats][climate_ref.results.diagnostics.DiagnosticsReader.stats] delegate
    here so the row-to-DTO mapping is defined exactly once.
    """
    from climate_ref.results.executions import ExecutionStats  # noqa: PLC0415

    return tuple(
        ExecutionStats(
            provider=row.provider,
            diagnostic=row.diagnostic,
            running=row.running,
            failed=row.failed,
            successful=row.successful,
            not_started=row.not_started,
            dirty=row.dirty,
            total=row.total,
        )
        for row in rows
    )