def _run_step(self, step_num, step_type, input_path, output_path,
                  working_dir, env):
        raise NotImplementedError("Subclass must implement this method")
Runner specific per step method
dataset/ETHPy150Open Yelp/mrjob/mrjob/sim.py/SimMRJobRunner._run_step