diff --git a/transfer_service/job_scheduler.py b/transfer_service/job_scheduler.py index 0e6beb93e17948547e46ade76be88e42d6f474cc..9fc75c34fa9a527a783a13882cc4d268909d3505 100644 --- a/transfer_service/job_scheduler.py +++ b/transfer_service/job_scheduler.py @@ -15,12 +15,12 @@ class JobScheduler(object): def __init__(self): self.taskExecutorList = [] - + 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": @@ -36,7 +36,7 @@ class JobScheduler(object): for taskExec in self.taskExecutorList: taskExec.start() running = False - while not running: + while not running: time.sleep(1) running = True for taskExec in self.taskExecutorList: