dcf574598f2e0ac2ea78de2b50738101f7ec987a,sos/sos_step.py,Base_Step_Executor,prepare_task,#Base_Step_Executor#,619

Before Change

            task_vars["__signature_vars__"], task_vars).sig_id

        job_file = os.path.join(os.path.expanduser("~"), ".sos", "tasks", task_id + ".def")
        with open(job_file, "wb") as jf:
            try:
                pickle.dump(param, jf)
            except Exception as e:
                env.logger.warning(e)
                raise

        return task_id

    def wait_for_results(self):
        results = self.pending_tasks([x for x in self.proc_results if isinstance(x, str)])

After Change

            task_vars["__signature_vars__"], task_vars).sig_id

        job_file = os.path.join(os.path.expanduser("~"), ".sos", "tasks", task_id + ".def")
        taskdef.save(job_file)
        return task_id

    def wait_for_results(self):
        results = self.pending_tasks([x for x in self.proc_results if isinstance(x, str)])

Instances