import logging import redis from rq import Queue, Worker from worker.config import settings logging.basicConfig(level=logging.INFO) if __name__ == "__main__": conn = redis.from_url(settings.redis_url) queue = Queue("generation", connection=conn) Worker([queue], connection=conn).work()