03f6c323579d0d9c92ea1b8559e55be67af9b6c1,pysos/sos_step.py,MP_Step_Executor,submit_task,#MP_Step_Executor#Any#,1153

Before Change

        else:
            // execute in existing process
            self.proc_results.append(
                execute_task(             // function
                self.step.task,           // task
                "",                       // local execusion, no need to re-run global
                // do not clone dict
                env.sos_dict,
                signature,
                self.step.sigil
                ))

    def wait_for_results(self):
        from multiprocessing.pool import AsyncResult

After Change

        if self.pool:
            param = TaskParams(
                name = "{} (index={})".format(self.step.step_name(), env.sos_dict["_index"]),
                data = (
                    self.step.task,         // task
                    self.step.global_def,    // global process

Instances