0c573dda88e351090519b6410e8fa53e05ff1250,dataset/research/workers.py,PipelineWorker,run_task,#PipelineWorker#,70

Before Change

                                else:
                                    item.next_batch(name)
                        if j in pipeline["dump_for"]:
                            self.post()
            except StopIteration:
                self.log_info("Task {} was stopped after {} iterations".format(i, j+1), filename=self.logfile)
                break

After Change

                        for item, config, repetition in zip(
                                    self.single_runnings,
                                    task["configs"],
                                    task["repetition"]
                            ):
                            path = os.path.join(
                                task["name"],
                                "results",

Instances