roastcoffea.export.reporter

Rich table formatting for metrics reporting.

Functions

format_chunk_metrics_table(metrics)

Format chunk-level metrics as Rich table.

format_event_processing_table(metrics)

Format event processing metrics as Rich table.

format_fine_metrics_table(metrics)

Format fine-grained metrics from Dask Spans as Rich table.

format_resources_table(metrics)

Format resource utilization metrics as Rich table.

format_throughput_table(metrics)

Format throughput metrics as Rich table.

format_timing_table(metrics)

Format timing metrics as Rich table.

roastcoffea.export.reporter.format_throughput_table(metrics)[source]

Format throughput metrics as Rich table.

Parameters:

metrics (dict) – Metrics dictionary

Returns:

Rich table

Return type:

Table

roastcoffea.export.reporter.format_event_processing_table(metrics)[source]

Format event processing metrics as Rich table.

Parameters:

metrics (dict) – Metrics dictionary

Returns:

Rich table

Return type:

Table

roastcoffea.export.reporter.format_resources_table(metrics)[source]

Format resource utilization metrics as Rich table.

Parameters:

metrics (dict) – Metrics dictionary

Returns:

Rich table

Return type:

Table

roastcoffea.export.reporter.format_timing_table(metrics)[source]

Format timing metrics as Rich table.

Parameters:

metrics (dict) – Metrics dictionary

Returns:

Rich table

Return type:

Table

roastcoffea.export.reporter.format_fine_metrics_table(metrics)[source]

Format fine-grained metrics from Dask Spans as Rich table.

Parameters:

metrics (dict) – Metrics dictionary

Returns:

Rich table if fine metrics available, None otherwise

Return type:

Table or None

roastcoffea.export.reporter.format_chunk_metrics_table(metrics)[source]

Format chunk-level metrics as Rich table.

Parameters:

metrics (dict) – Metrics dictionary

Returns:

Rich table, or None if no chunk metrics available

Return type:

Table or None