Loading transfer_service/job_scheduler.py +4 −4 Original line number Diff line number Diff line Loading @@ -18,9 +18,9 @@ class JobScheduler(object): def addTaskExecutor(self, taskExecType): if taskExecType == "group_rw_executor": self.taskExecutorList.append(ImportExecutor()) elif taskExecType == "import_executor": self.taskExecutorList.append(GroupRwExecutor()) elif taskExecType == "import_executor": self.taskExecutorList.append(ImportExecutor()) elif taskExecType == "retrieve_preprocessor": self.taskExecutorList.append(RetrievePreprocessor()) elif taskExecType == "store_preprocessor": Loading Loading
transfer_service/job_scheduler.py +4 −4 Original line number Diff line number Diff line Loading @@ -18,9 +18,9 @@ class JobScheduler(object): def addTaskExecutor(self, taskExecType): if taskExecType == "group_rw_executor": self.taskExecutorList.append(ImportExecutor()) elif taskExecType == "import_executor": self.taskExecutorList.append(GroupRwExecutor()) elif taskExecType == "import_executor": self.taskExecutorList.append(ImportExecutor()) elif taskExecType == "retrieve_preprocessor": self.taskExecutorList.append(RetrievePreprocessor()) elif taskExecType == "store_preprocessor": Loading