worker.py - master - tsps/case_loader

# точка входа для воркера
import os
import sys

# Добавляем корень проекта в PYTHONPATH, чтобы импорты работали
sys.path.insert(0, os.path.dirname(os.path.abspath(__file__)))

import logging
logging.basicConfig(
    level=logging.INFO,
    format="%(asctime)s - %(name)s - %(levelname)s - %(message)s"
)

from app.core.queue import case_loader_queue
from rq import Worker

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