Source code for

OR Aggregator

Aggregator that identifies a time step as anomalous if any of the components
is flagged as anomalous (logical OR).

from typing import Sequence

from darts import TimeSeries
from import NonFittableAggregator

[docs]class OrAggregator(NonFittableAggregator): def __init__(self) -> None: super().__init__() def __str__(self): return "OrAggregator" def _predict_core(self, series: Sequence[TimeSeries]) -> Sequence[TimeSeries]: return [s.sum(axis=1).map(lambda x: (x > 0).astype(s.dtype)) for s in series]