task_executor.py

import time

from multiprocessing import Process

from config import Config
from job_queue import JobQueue


class TaskExecutor(Process):

    def __init__(self):
        config = Config("vos_ts.conf")
        self.params = config.loadSection("scheduling")
        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.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