def _subprocess_env(self, step_num, step_type, task_num, working_dir,
                        **split_kwargs):
        user_jobconf = self._jobconf_for_step(step_num)

        simulated_jobconf = self._simulate_jobconf_for_step(
            step_num, step_type, task_num, working_dir, **split_kwargs)

        def to_env(jobconf):
            return dict((k.replace('.', '_'), str(v))
                        for k, v in jobconf.items())

        # keep the current environment because we need PATH to find binaries
        # and make PYTHONPATH work
        return combine_local_envs(os.environ,
                                  to_env(user_jobconf),
                                  to_env(simulated_jobconf),
                                  self._opts['cmdenv'])
Set up environment variables for a subprocess (mapper, etc.)
dataset/ETHPy150Open Yelp/mrjob/mrjob/sim.py/SimMRJobRunner._subprocess_env