Skip to content

climate_ref.cli.diagnostics #

View diagnostic metadata

list_(ctx, provider=None, diagnostic=None, column=None, limit=typer.Option(100, min=0, help='Limit the number of rows to display'), output_format=OutputFormat.table) #

List the registered diagnostics.

Columns:

  • provider: the provider slug.
  • diagnostic: the diagnostic slug.
  • name: the human-readable diagnostic name.
  • promoted_version: the currently promoted diagnostic version.
  • group_count: execution groups at the promoted version.
  • successful_group_count: groups whose latest execution succeeded.
  • failed_group_count: groups whose latest execution failed.
  • running_group_count: groups whose latest execution is still running.
  • not_started_group_count: groups with no execution yet.
  • dirty_group_count: groups marked to be rerun.
  • execution_count: number of executions at the promoted version, counting every rerun.
Source code in packages/climate-ref/src/climate_ref/cli/diagnostics.py 
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
@app.command(name="list")
def list_(  # noqa: PLR0913
    ctx: typer.Context,
    provider: Annotated[
        list[str] | None,
        typer.Option(
            help="Filter by provider slug (substring match, case-insensitive). "
            "Multiple values can be provided."
        ),
    ] = None,
    diagnostic: Annotated[
        list[str] | None,
        typer.Option(
            help="Filter by diagnostic slug (substring match, case-insensitive). "
            "Multiple values can be provided."
        ),
    ] = None,
    column: Annotated[
        list[str] | None,
        typer.Option(help="Only include specified columns in the output"),
    ] = None,
    limit: int = typer.Option(100, min=0, help="Limit the number of rows to display"),
    output_format: Annotated[
        OutputFormat,
        typer.Option(
            "--format",
            help="Output format: 'table' (default) or machine-readable 'json'.",
        ),
    ] = OutputFormat.table,
) -> None:
    """
    List the registered diagnostics.

    Columns:

    - provider: the provider slug.
    - diagnostic: the diagnostic slug.
    - name: the human-readable diagnostic name.
    - promoted_version: the currently promoted diagnostic version.
    - group_count: execution groups at the promoted version.
    - successful_group_count: groups whose latest execution succeeded.
    - failed_group_count: groups whose latest execution failed.
    - running_group_count: groups whose latest execution is still running.
    - not_started_group_count: groups with no execution yet.
    - dirty_group_count: groups marked to be rerun.
    - execution_count: number of executions at the promoted version, counting every rerun.
    """
    console = ctx.obj.console
    reader = Reader(ctx.obj.database)

    collection = reader.diagnostics.list(
        DiagnosticFilter(provider_contains=provider, diagnostic_contains=diagnostic),
        limit=limit,
    )

    results_df = collection.to_pandas()

    if column:
        if not all(col in results_df.columns for col in column):
            logger.error(f"Column not found: {column}")
            raise typer.Exit(code=1)
        results_df = results_df[column]

    render_dataframe(results_df, console=console, output_format=output_format)

    filtered_count = collection.total_count or 0
    if filtered_count > limit:
        logger.warning(
            f"Displaying {limit} of {filtered_count} filtered results. "
            f"Use the `--limit` option to display more."
        )