0c573dda88e351090519b6410e8fa53e05ff1250,dataset/research/workers.py,PipelineWorker,init,#PipelineWorker#,28

Before Change

                n_branches = Config()

            worker_config = self.kwargs.get("config", Config())
            self.log_info(worker_config, filename=self.logfile)

            single_running.add_common_config(config.config()+n_branches+worker_config)
            single_running.init()
            self.single_runnings.append(single_running)

After Change

                if pipeline["dump_for"] is not None:
                    pipeline["dump_for"] = self.get_iterations(pipeline["dump_for"], task["n_iters"])
                else:
                    pipeline["dump_for"] = []
                single_running.add_pipeline(pipeline_copy, pipeline["var"],
                                            name=name, post_run=pipeline["post_run"], **pipeline["kwargs"])
            if isinstance(task["n_branches"], list):

Instances