self.ended = False
def process_event(self, ev):
+ self._check_analysis_end(ev)
+ if self.ended:
+ return
+
self._last_event_ts = ev.timestamp
if not self.started:
self._period_start_ts = ev.timestamp
self.started = True
- self._check_analysis_end(ev)
- if self.ended:
- return
-
# Prioritise period events over refresh period
if self._conf.period_begin_ev_name is not None:
self._handle_period_event(ev)