in lambda/states/manager.py [0:0]
def process(self, frame):
frame_timestamp = frame['timestamp']
if self.end_time and frame_timestamp > self.end_time:
self.change_current_state(states.fail.FailState())
return
success = self.current_state.process(frame)
if success is not None:
if success:
next_state = self.current_state = self.current_state.get_next_state_success()
else:
next_state = self.current_state = self.current_state.get_next_state_failure()
self.change_current_state(next_state, frame_timestamp)
return