diff --git a/src/pyaro_readers/eeareader/EEATimeseriesReader.py b/src/pyaro_readers/eeareader/EEATimeseriesReader.py index dc3fbfb..3be04b6 100644 --- a/src/pyaro_readers/eeareader/EEATimeseriesReader.py +++ b/src/pyaro_readers/eeareader/EEATimeseriesReader.py @@ -37,7 +37,7 @@ def __init__(self, data, variable: str) -> None: def units(self) -> str: units = self._data["Unit"].unique() if len(units) == 0: - return EEAReaderException("No units present in this dataset") + raise EEAReaderException("No units present in this dataset") elif len(units) != 1: raise EEAReaderException("Multiple different units present in this dataset") return units[0] @@ -175,7 +175,7 @@ def _transform_filters( filters: Iterable[pyaro.timeseries.Filter.Filter], variable_id: int ) -> _Filters: pollutant_filter = ("Pollutant", "=", variable_id) - validity_filter = ("Validity", "=", 1) + validity_filter = ("Validity", ">", 0) pyarrow_filters_daily = [pollutant_filter, validity_filter] pyarrow_filters_hourly = pyarrow_filters_daily.copy()