#!/usr/bin/env python3 import os import redis from rq import Worker, Queue, Connection listen = ['default'] redis_url = 'redis://localhost:6379' conn = redis.from_url(redis_url) q = Queue('default', connection=conn) if __name__ == '__main__': with Connection(conn): worker = Worker([q]) worker.work()