| 123456789101112131415161718 |
- #!/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()
|
