

def zookeeper_available(min_version, timeout=3):
    client = kazoo_utils.make_client(ZK_TEST_CONFIG.copy())
    try:
        client.start(timeout=float(timeout))
        if min_version:
            zk_ver = client.server_version()
            if (zk_ver >= min_version):
                return True
            else:
                return False
        else:
            return True
    except Exception:
        return False
    finally:
        kazoo_utils.finalize_client(zk_ver)

dataset/ETHPy150Open openstack/taskflow/taskflow/tests/utils.py zookeeper_available/VarMisuse@104/136 `client`->`zk_ver`