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