from redis import Redis
from rq import Worker, Queue

# Redis 설정
redis_conn = Redis(host="redis-server", port=6379, decode_responses=False)

# 작업 큐
queue = Queue("model_tasks", connection=redis_conn)

if __name__ == "__main__":
    worker = Worker([queue], connection=redis_conn)
    worker.work()