app/worker.py

import redis
from rq import Queue, Connection, Worker
from app.config import settings
from loguru import logger

listen = ["default"]
conn = redis.Redis.from_url(settings.REDIS_URL)

def run_worker():
    logger.info(f"Starting RQ worker connecting to Redis at {settings.REDIS_URL}")
    with Connection(conn):
        worker = Worker(list(map(Queue, listen)))
        worker.work()

if __name__ == "__main__":
    run_worker()