15 lines
375 B
Python
15 lines
375 B
Python
import os
|
|
import redis
|
|
from rq import Queue
|
|
|
|
|
|
def get_redis_url() -> str:
|
|
# Default to local Redis service name in compose network
|
|
return os.getenv("REDIS_URL", "redis://redis:6379/0")
|
|
|
|
|
|
def get_queue(name: str = "conversions") -> Queue:
|
|
conn = redis.from_url(get_redis_url())
|
|
# 10 minutes default
|
|
return Queue(name, connection=conn, default_timeout=600)
|