File tree Expand file tree Collapse file tree 2 files changed +4
-4
lines changed
src/frequenz/sdk/timeseries/battery_pool Expand file tree Collapse file tree 2 files changed +4
-4
lines changed Original file line number Diff line number Diff line change 2525_logger = logging .getLogger (__name__ )
2626
2727
28- class AggregateMethod (Generic [T ], ABC ):
28+ class MetricAggregator (Generic [T ], ABC ):
2929 """Interface to control how the component data should be aggregated and send."""
3030
3131 @abstractmethod
@@ -61,7 +61,7 @@ def name(cls) -> str:
6161 """
6262
6363
64- class SendOnUpdate (AggregateMethod [T ]):
64+ class SendOnUpdate (MetricAggregator [T ]):
6565 """Wait for the change of the components metrics and send updated result.
6666
6767 This method will cache the component metrics. When any metric change it will
Original file line number Diff line number Diff line change 2525 FormulaGeneratorConfig ,
2626 FormulaType ,
2727)
28- from ._methods import AggregateMethod , SendOnUpdate
28+ from ._methods import MetricAggregator , SendOnUpdate
2929from ._metric_calculator import CapacityCalculator , PowerBoundsCalculator , SoCCalculator
3030from ._result_types import CapacityMetrics , PowerMetrics , SoCMetrics
3131
@@ -85,7 +85,7 @@ def __init__( # pylint: disable=too-many-arguments
8585 )
8686
8787 self ._min_update_interval = min_update_interval
88- self ._active_methods : dict [str , AggregateMethod [Any ]] = {}
88+ self ._active_methods : dict [str , MetricAggregator [Any ]] = {}
8989
9090 self ._namespace : str = f"battery-pool-{ self ._batteries } -{ uuid .uuid4 ()} "
9191 self ._formula_pool : FormulaEnginePool = FormulaEnginePool (
You can’t perform that action at this time.
0 commit comments