Rooba
/
kombu
mirror of https://github.com/celery/kombu.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Cosmetics

This commit is contained in:
Ask Solem 2015-02-12 00:20:55 +00:00
parent aaaa2781e2
commit 339b6d2afe
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kombu/transport/zookeeper.py
View File

@ -153,7 +153,7 @@ class Channel(virtual.Channel):
if not host_port:
continue
try:
host, port = host_port.split(":", 1)
host, port = host_port.split(':', 1)
host_port = (host, int(port))
except ValueError:
if host_port == conninfo.hostname:
@ -164,7 +164,7 @@ class Channel(virtual.Channel):
host_port = (conninfo.hostname, conninfo.port or DEFAULT_PORT)
if host_port not in hosts:
hosts.insert(0, host_port)
conn_str = ",".join(["%s:%s" % (host, port) for (host, port) in hosts])
conn_str = ",".join(['%s:%s' % (host, port) for host, port in hosts])
conn = KazooClient(conn_str)
conn.start()
return conn