diff --git a/saqc/lib/rolling.py b/saqc/lib/rolling.py index 323cf1789756af4af95e9fb3f36eea79ab618fc7..22bfbccfcb4652ba7b6c6d9fe1d45cc378b72137 100644 --- a/saqc/lib/rolling.py +++ b/saqc/lib/rolling.py @@ -86,6 +86,10 @@ class _CustomBaseIndexer(BaseIndexer): center = self._center start, end = self._get_bounds(num_values, min_periods, center, closed) + + # ensure correct length + start, end = start[:num_values], end[:num_values] + start, end = self._apply_skipmask(start, end) start, end = self._apply_steps(start, end, num_values) start, end = self._prepare_min_periods_masking(start, end, num_values)