master.py

#!/usr/bin/env python

import random
import time

from manager import QueueClient


class Master(QueueClient):
    def run(self):
        while True:
            task = random.randint(5, 1e3)
            print('new task:', task)
            self.queue.put(task)
            time.sleep(random.randint(1, 10))


if __name__ == '__main__':
    Master().run()