roastcoffea.aggregation.backends.base

Abstract base class for tracking data parsers.

This module defines the interface that all aggregation backend parsers must follow.

Classes

AbstractTrackingDataParser()

Abstract base class for parsing backend tracking data.
class roastcoffea.aggregation.backends.base.AbstractTrackingDataParser[source]

Bases: ABC

Abstract base class for parsing backend tracking data.

Parsers are responsible for converting raw tracking data from different backends (Dask, TaskVine, etc.) into a standardized metrics format.

abstractmethod parse_tracking_data(tracking_data)[source]

Parse raw tracking data into aggregated metrics.

Parameters:

tracking_data (dict) – Raw tracking data from backend (e.g., worker_counts, worker_memory)

Returns:

Aggregated worker metrics (avg_workers, peak_workers, total_cores, etc.)

Return type:

dict