def work(): print("Hello from the worker side.") with Connection(REDIS): worker = Worker(map(Queue, QUEUES)) worker.work()