services/redis_queue.py

import redis
from rq import Queue
import os

redis_conn = redis.Redis(
    host=os.getenv("REDIS_HOST"),
    port=os.getenv("REDIS_PORT"),
    password=os.getenv("REDIS_PASSWORD"),
    decode_responses=True
)

queue = Queue(connection=redis_conn)