minion.py

#!/usr/bin/env python3

from manager import QueueClient


class Minion(QueueClient):
    def run(self):
        while True:
            task = self.tasks.get()
            print(f'start work on a task {task.identifier} of size {task.size}...')
            task.work()
            print(f'Done in {task.time:.3f}s')
            self.results.put(task)


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