#!/usr/bin/env python import random import time from manager import QueueClient class Minion(QueueClient): def run(self): while True: task = self.queue.get() print('got task', task) time.sleep(random.randint(5, 15)) print('work done for task', task) print('result is', task ** 3) if __name__ == '__main__': Minion().run()