'Process observation for metrics.'

def observe(self, observation):

    if (self.lastY is not None):
        self.metrics.update(observation, self.lastY)
        self.lastY = None
    return observation
