video_encoder/worker/worker.py

from rq import Worker
from video_encoder.config import RedisConfig

import logging
logger = logging.getLogger(__name__)

if __name__ == "__main__":
    try:
        logger.info("Starting RQ worker")
        worker = Worker([RedisConfig.QUEUE_NAME], connection=RedisConfig.get_connection(), default_result_ttl=3600)
        logger.info("RQ worker started successfully")
        worker.work()
    except Exception as e:
        logger.error(f"Failed to start RQ worker: {str(e)}")