File size: 479 Bytes
89c32de
7cdd60d
89c32de
a4f374c
 
 
89c32de
a4f374c
 
 
 
 
 
 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
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)}")