From 71a2b69560bf202460bbe90d8747316be780a471 Mon Sep 17 00:00:00 2001 From: Cristiano Urban Date: Sat, 26 Jun 2021 10:37:51 +0200 Subject: [PATCH] Fixed typo. Signed-off-by: Cristiano Urban --- transfer_service/job_scheduler.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/transfer_service/job_scheduler.py b/transfer_service/job_scheduler.py index 0e6beb9..9fc75c3 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: -- GitLab