File size: 428 Bytes
50925ca | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 | 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()
|