03f6c323579d0d9c92ea1b8559e55be67af9b6c1,pysos/sos_step.py,RQ_Step_Executor,submit_task,#RQ_Step_Executor#Any#,1223

Before Change

            walltime = 60*60*24*30 
        //
        // tell subprocess where pysos.runtime is
        self.proc_results.append(
            self.redis_queue.enqueue(
            execute_task,            // function
            args=(self.step.task,          // task
            self.step.global_def,    // global process
            // if pool, it must not be in prepare mode and have
            // __signature_vars__
            env.sos_dict.clone_selected_vars(env.sos_dict["__signature_vars__"] \
                | {"_input", "_output", "_depends", "input", "output",
                    "depends", "_index", "__args__", "step_name", "_runtime"}),
            signature,
            self.step.sigil
            ),
            timeout=walltime))

    def wait_for_results(self):
        while True:
            // wait for results

After Change

            walltime = 60*60*24*30 
        //
        // tell subprocess where pysos.runtime is
        param = TaskParams(
            name = "{} (index={})".format(self.step.step_name(), env.sos_dict["_index"]),
            data = (
                self.step.task,          // task
                self.step.global_def,    // global process
                // if pool, it must not be in prepare mode and have
                // __signature_vars__
                env.sos_dict.clone_selected_vars(env.sos_dict["__signature_vars__"] \
                    | {"_input", "_output", "_depends", "input", "output",
                        "depends", "_index", "__args__", "step_name", "_runtime"}),
                signature,
                self.step.sigil
            ))

        self.proc_results.append(
            self.redis_queue.enqueue(
            execute_task,            // function
            args=(param,),
            timeout=walltime))

    def wait_for_results(self):
        while True:
            // wait for results

Instances