

def _make_index_iterator(self, start_run_idx):
    'Returns an iterator over the run indices that are not completed'
    total_runs = len(self._traj)
    for n in compat.xrange(start_run_idx, total_runs):
        self._current_idx = (n + 1)
        if self._stop_iteration:
            self._logger.debug('I am stopping new run iterations now!')
            break
        if (not self._traj._is_completed(n)):
            self._traj.f_set_crun(n)
            (yield n)
        else:
            self._logger.debug(('Run `%d` has already been completed, I am skipping it.' % n))

dataset/ETHPy150Open SmokinCaterpillar/pypet/pypet/environment.py Environment._make_index_iterator/original