Make qr take redis connection params from the general redis connection

This commit is contained in:
Arik Fraimovich 2013-11-04 15:51:58 +02:00
parent 18e56fab57
commit 7ca1b5e761

View File

@ -30,7 +30,7 @@ class Manager(object):
self.workers = []
self.db_connection_pool = psycopg2.pool.ThreadedConnectionPool(1, db_max_connections,
db_connection_string)
self.queue = qr.PriorityQueue("jobs")
self.queue = qr.PriorityQueue("jobs", **self.redis_connection.connection_pool.connection_kwargs)
self.max_retries = 5
# TODO: Use our Django Models