connection_retry parameter doesn't seem to do anything

[fabrice...@gmail.com]

Hello list,

I got the following:

        self.zk = KazooClient(hosts=self.options.zk_hostlist,
                              connection_retry=KazooRetry(max_tries=-1,
                                                          sleep_func=handler.sleep_func),
                              handler=handler)

I'm not too sure about sleep_func=handler.sleep_func; handler might be a SequentialGeventHandler or a SequentialThreadingHandler depending on the usage and this is the only way I got it to stop complaining that the "retry handler and event handler must use the same sleep func".

As I understand it from the doc of KazooRetry, this should attempt to connect forever. Instead:

executor_1   | INFO:kazoo.client:Connecting to zookeeper:2181
executor_1   | WARNING:kazoo.client:Connection dropped: socket connection error: Connection refused
executor_1   | INFO:kazoo.client:Connecting to zookeeper:2181
executor_1   | WARNING:kazoo.client:Connection dropped: socket connection error: Connection refused
executor_1   | INFO:kazoo.client:Connecting to zookeeper:2181
executor_1   | WARNING:kazoo.client:Connection dropped: socket connection error: Connection refused
executor_1   | INFO:kazoo.client:Connecting to zookeeper:2181
executor_1   | WARNING:kazoo.client:Connection dropped: socket connection error: Connection refused
executor_1   | INFO:kazoo.client:Connecting to zookeeper:2181
executor_1   | WARNING:kazoo.client:Connection dropped: socket connection error: Connection refused
executor_1   | INFO:kazoo.client:Connecting to zookeeper:2181
executor_1   | WARNING:kazoo.client:Connection dropped: socket connection error: Connection refused
executor_1   | INFO:kazoo.client:Connecting to zookeeper:2181
executor_1   | WARNING:kazoo.client:Connection dropped: socket connection error: Connection refused
executor_1   | WARNING:kazoo.client:Failed connecting to Zookeeper within the connection retry policy.
executor_1   | INFO:kazoo.client:Zookeeper session lost, state: CLOSED

I grepped through the source code and I can't find anywhere that the _conn_retry attribute is actually used, did I miss something?