ZooKeeper: replace deprecated connect() with start().

This commit is contained in:
Neil Williams
2012-10-25 10:56:20 -07:00
parent b55934ab6f
commit 463d969ad0

View File

@@ -46,7 +46,7 @@ def connect_to_zookeeper(hostlist, credentials):
# convenient helper function for making credentials
client.make_acl = functools.partial(make_digest_acl, *credentials)
client.connect()
client.start()
client.add_auth("digest", ":".join(credentials))
return client