From 159c4c297faf8802deaa9f1106603a4eb4d48a0b Mon Sep 17 00:00:00 2001 From: Cristiano Urban Date: Wed, 13 Jan 2021 12:22:45 +0100 Subject: [PATCH] Modified to provide a generic behavior for a task or a set of tasks. Signed-off-by: Cristiano Urban --- transfer_service/task_executor.py | 18 ++++++++++++------ 1 file changed, 12 insertions(+), 6 deletions(-) diff --git a/transfer_service/task_executor.py b/transfer_service/task_executor.py index 9715af2..a937e23 100644 --- a/transfer_service/task_executor.py +++ b/transfer_service/task_executor.py @@ -6,7 +6,7 @@ from config import Config from job_queue import JobQueue -class Preprocessor(Process): +class TaskExecutor(Process): def __init__(self): config = Config("vos_ts.conf") @@ -14,16 +14,22 @@ class Preprocessor(Process): self.maxPendingJobs = self.params.getint("max_pending_jobs") self.maxReadyJobs = self.params.getint("max_ready_jobs") self.execWaitTime = self.params.getint("exec_wait_time") - self.pendingQueue = JobQueue("pending") - self.readyQueue = JobQueue("ready") - super(Preprocessor, self).__init__() - + self.srcQueue = None + self.destQueue = None + super(TaskExecutor, self).__init__() + def wait(self): time.sleep(self.execWaitTime) + def setSourceQueueName(self, srcQueueName): + self.srcQueue = JobQueue(srcQueueName) + + def setDestinationQueueName(self, destQueueName): + self.destQueue = JobQueue(destQueueName) + def run(self): """ This method must be implemented by inherited classes """ - pass \ No newline at end of file + pass -- GitLab