diff --git a/python/fusion_engine_client/parsers/mixed_log_reader.py b/python/fusion_engine_client/parsers/mixed_log_reader.py index f6341f26..700117fa 100644 --- a/python/fusion_engine_client/parsers/mixed_log_reader.py +++ b/python/fusion_engine_client/parsers/mixed_log_reader.py @@ -591,6 +591,8 @@ def filter_in_place(self, key, clear_existing: Union[bool, str] = False, if self.index is not None: if len(self.index) == 0: self.next_index_elem = 0 + elif prev_offset_bytes < 0: + self.next_index_elem = 0 else: idx = np.argmax(self.index.offset > prev_offset_bytes) if idx == 0 and self.index.offset[0] <= prev_offset_bytes: