Chandima Prabhath
Refactor worker initialization in run.py to use subprocess for improved process management; add worker.py for dedicated worker handling
795176c
raw
history blame contribute delete
200 Bytes
from rq import Worker
from video_encoder.config import RedisConfig
if __name__ == "__main__":
worker = Worker([RedisConfig.QUEUE_NAME], connection=RedisConfig.get_connection())
worker.work()