Support password for redis+socket://. Closes #460

celery · Apr 17, 2015 · d720d33 · d720d33
1 parent e1e5797
commit d720d33
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/kombu/transport/redis.py b/kombu/transport/redis.py
@@ -782,11 +782,12 @@ def _connparams(self):
                       'socket_timeout': self.socket_timeout}
         host = connparams['host']
         if '://' in host:
-            scheme, _, _, _, _, path, query = _parse_url(host)
+            scheme, _, _, _, password, path, query = _parse_url(host)
             if scheme == 'socket':
                 connparams.update({
                     'connection_class': redis.UnixDomainSocketConnection,
-                    'path': '/' + path}, **query)
+                    'path': '/' + path,
+                    'password': password}, **query)
             connparams.pop('host', None)
             connparams.pop('port', None)
         connparams['db'] = self._prepare_virtual_host(
@@ -796,7 +797,7 @@ def _connparams(self):
         connection_cls = (
             connparams.get('connection_class') or
             redis.Connection
-            )
+        )
 
         class Connection(connection_cls):
             def disconnect(self):