File tree Expand file tree Collapse file tree 1 file changed +7
-2
lines changed Expand file tree Collapse file tree 1 file changed +7
-2
lines changed Original file line number Diff line number Diff line change @@ -42,7 +42,10 @@ def str_to_class(s):
42
42
43
43
class ResQ (object ):
44
44
45
- def __init__ (self , server = "localhost:6379" , password = None ):
45
+ def __init__ (self , server = "localhost:6379" , password = None ,
46
+ timeout = None , retry_connection = True ):
47
+ self .timeout = timeout
48
+ self .retry_connection = retry_connection
46
49
self .redis = server
47
50
if password :
48
51
self .redis .auth (password )
@@ -85,7 +88,9 @@ def _set_redis(self, server):
85
88
if isinstance (server , basestring ):
86
89
self .dsn = server
87
90
host , port = server .split (':' )
88
- self ._redis = Redis (host = host , port = int (port ))
91
+ self ._redis = Redis (host = host , port = int (port ),
92
+ retry_connection = self .retry_connection ,
93
+ timeout = self .timeout )
89
94
elif isinstance (server , Redis ):
90
95
self .dsn = '%s:%s' % (server .host ,server .port )
91
96
self ._redis = server
You can’t perform that action at this time.
0 commit comments