Function do_get has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

    def do_get(self, params):
        """
\x1b[1mNAME\x1b[0m
        get - Gets the znode's value

• Read up
  Read up

Function pretty_bytes has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

def pretty_bytes(num):
    """ pretty print the given number of bytes """
    for unit in ['', 'KB', 'MB', 'GB']:
        if num < 1024.0:
            if unit == '':

• Read up
  Read up

Function do_json_set has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

    def do_json_set(self, params):
        """
\x1b[1mNAME\x1b[0m
        json_set - Sets the value for the given (possibly nested) key on a JSON object serialized in the given path

• Read up
  Read up

Function _init_zk_client has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

    def _init_zk_client(self, hosts_list):
        """
        Initialize the zookeeper client (based on the provided list of hosts.

        In the basic case, hostsp is a list of hosts like:

• Read up
  Read up

Function valid_ipv4 has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

def valid_ipv4(ip):
    """ check if ip is a valid ipv4 """
    match =  _valid_ipv4.match(ip)
    if match is None:
        return False

• Read up
  Read up

Function add has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

    def add(self, path, debug, children):
        """
        Set a watch for path and (maybe) its children depending on the value
        of children:

• Read up
  Read up

Function get_acls_recursive has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

    def get_acls_recursive(self, path, depth, include_ephemerals):
        """A recursive generator wrapper for get_acls

        :param path: path from which to start
        :param depth: depth of the recursion (-1 no recursion, 0 means no limit)

• Read up
  Read up

Function grep has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

    def grep(self, path, content, flags, show_matches):
        for path, matches in self._zk.grep(path, content, flags):
            if show_matches:
                self.show_output("%s:", path)
                for match in matches:

• Read up
  Read up

Function check_path_absent has a Cognitive Complexity of 7 (exceeds 5 allowed). Consider refactoring.

Open

def check_path_absent(func):
    """
    check path doesn't exist (unless we are in a txn or it's sequential)

    note: when creating sequential znodes, a trailing slash means no prefix, i.e.:

• Read up
  Read up

Avoid too many return statements within this function.

Open

        return json.loads(value)

Avoid too many return statements within this function.

Open

    return True

Avoid too many return statements within this function.

Open

    return ValueError('Unknown type')

Avoid too many return statements within this function.

Open

            return False

Avoid too many return statements within this function.

Open

            return

Function safe_list_set has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

def safe_list_set(plist, idx, fill_with, value):
    """
    Sets:

    ```

• Read up
  Read up

Function do_set_acls has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def do_set_acls(self, params):
        """
\x1b[1mNAME\x1b[0m
        set_acls - Sets ACLs for a given path

• Read up
  Read up

Function sessions_info has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def sessions_info(self, hosts):
        """Returns ClientInfo per session.

        :param hosts: comma separated lists of members of the ZK ensemble.
        :returns: A dictionary of (session_id, ClientInfo).

• Read up
  Read up

Function do_diff has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def do_diff(self, params):
        """
\x1b[1mNAME\x1b[0m
        diff - Display the differences between two paths

• Read up
  Read up

Function check_path has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def check_path(self):
        try:
            retval = True if self.client.exists(self.path) else False
        except NoAuthError:
            raise AuthError("read", self.path)

• Read up
  Read up

Function _watch has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    def _watch(self, path, current_level, max_level):
        """
        we need to catch ZNONODE because children might be removed whilst we
        are iterating (specially ephemeral znodes)
        """

• Read up
  Read up