Function import_tables has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

def import_tables(options, sources, files_ignored=None):
    # Make sure this isn't a pre-`reql_admin` cluster - which could result in data loss
    # if the user has a database named 'rethinkdb'
    utils_common.check_minimum_version(options, "1.6")

Function _handleResponse has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def _handleResponse(self, data):
        # If we have more than one response, we should handle all of them.
        self.buf += data
        while True:
            # 1. Read the header, until we read the length of the awaited payload.

• Read up
  Read up

Function teardown has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def teardown(self):

        # - check the end of the file
        # note: fill_buffer should have guaranteed that we have only the data in the end

• Read up
  Read up

Function sendall has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def sendall(self, data):
        offset = 0
        while offset < len(data):
            try:
                offset += self._socket.send(data[offset:])

• Read up
  Read up

Function _handleHandshake has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def _handleHandshake(self, data):
        try:
            self.buf += data
            while True:
                end_index = self.buf.find(b"\0")

• Read up
  Read up

Function __init__ has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def __init__(
        self,
        conn_type,
        host,
        port,

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                    if _dnsname_match(value, hostname):
                        return
                    dnsnames.append(value)

Function _dnsname_match has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

def _dnsname_match(domain_name, hostname, max_wildcards=1):
    """Matching according to RFC 6125, section 6.4.3

    http://tools.ietf.org/html/rfc6125#section-6.4.3
    """

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                        if item not in fields:
                            del row[item]
                if first:

Avoid deeply nested control flow statements.

Open

                    if ext not in [".json", ".csv", ".info"]:
                        files_ignored.append(os.path.join(root, filename))
                    elif ext == ".info":
                        pass  # Info files are included based on the data files
                    elif not os.path.exists(os.path.join(root, table + ".info")):

Avoid deeply nested control flow statements.

Open

                    for dir_name in dirs[:]:  # iterate on a copy
                        if dir_name not in db_filter:
                            dirs.remove(dir_name)
            else:

Avoid deeply nested control flow statements.

Open

                        if str == unicode:
                            info.append(json.dumps(row[field]))
                        else:
                            info.append(json.dumps(row[field]).encode("utf-8"))
                out_writer.writerow(info)

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

Open

    def setup_file(self, warning_queue=None):
        # - move to the first record

        # advance through any leading whitespace
        while True:

• Read up
  Read up

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

Open

    def parse_args(self, *args, **kwargs):
        # - validate options

        connect = True
        if "connect" in kwargs:

• Read up
  Read up

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

Open

    def get_line(self):
        """Return a line from the current _buffer_str, or raise NeedMoreData trying"""

        # advance over any whitespace
        self._buffer_pos = json.decoder.WHITESPACE.match(

• Read up
  Read up

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

Open

    def set_loop_type(self, library=None):
        if library == "asyncio":
            from rethinkdb.asyncio_net import net_asyncio
            self.connection_type = net_asyncio.Connection

• Read up
  Read up

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

Open

    def __iter__(self):
        itr = iter(self.seq)

        try:
            for sub in next(itr):

• Read up
  Read up

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

Open

def make_connection(
    connection_type,
    host=None,
    port=None,
    db=None,

• Read up
  Read up

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

Open

def main(argv=None, prog=None):
    options = parse_options(argv or sys.argv[1:], prog=prog)
    start_time = time.time()
    try:
        rebuild_indexes(options)

• Read up
  Read up

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

Open

    def compose_carrots(self, term, frames):
        # This term is the cause of the error
        if len(frames) == 0:
            return ["^" for i in self.compose_term(term)]

• Read up
  Read up