def METHOD_NAME(self, stage):
    self.make_callback('pipeline-start', stage)
    self._i = self.pipeline.index(stage)
    start_time = time.time()
    while self._i < len(self.pipeline):
        self.run_stage_idx(self._i)
        self._i += 1
    stop_time = time.time()
    self.logger.debug("pipeline '%s' total execution %.4f sec" % (
        self.name, stop_time - start_time))