Avoid deeply nested control flow statements.

Open

                        if capabilities_differ.diffs:
                            str_changes.append('  capabilities:')
                            str_changes.extend(
                                ['  {0}'.format(change) for change in
                                 capabilities_differ.changes_str2.split('\n')])

Avoid deeply nested control flow statements.

Open

                        if dvs[infra_prop][idx] != \
                           current_dvs[infra_prop][idx]:

                            original_infra_res_pools.append(
                                current_dvs[infra_prop][idx])

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

Open

def _configure(changes):

    '''
    Calls the configuration template to apply the configuration changes on the device.
    '''

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                        if len(found) < len(minions):
                            fail = sorted(list(minions.difference(found)))
                            for minion in fail:
                                ret[minion] = {
                                    'out': 'no_return',

Avoid deeply nested control flow statements.

Open

                            while True:
                                ret = que.get(False)
                                if 'id' in ret:
                                    returned.add(ret['id'])
                                    yield {ret['id']: ret['ret']}

Avoid deeply nested control flow statements.

Open

                        if not os.path.exists(os.path.join(self.opts['syndic_dir'], id_)):
                            yield {
                                id_: {
                                    'out': 'no_return',
                                    'ret': 'Minion did not return. [No response]'

Avoid deeply nested control flow statements.

Open

                        if hostname in [host_id, roster_data.get('host')]:
                            if hostname != self.opts['tgt']:
                                self.opts['tgt'] = hostname
                            self.__parsed_rosters[self.ROSTER_UPDATE_FLAG] = False
                            return

Avoid deeply nested control flow statements.

Open

                        if subprofile_differ.diffs:
                            str_changes.extend(
                                ['  {0}'.format(change) for change in
                                 subprofile_differ.changes_str.split('\n')])
                        if capabilities_differ.diffs:

Avoid deeply nested control flow statements.

Open

                    if not os.path.isdir(tgt_dir):
                        os.makedirs(tgt_dir)
                    shutil.copy(path, tgt)

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

Open

    def format_logstash_v1(self, record):
        '''
        Messages are formatted in logstash's expected format.
        '''
        message_dict = {

• Read up
  Read up

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

Open

    def handleError(self, record):
        '''
        Override the default error handling mechanism

        Deal with log file rotation errors due to log file in use

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                        if params['retcode'] == retcode:
                            continue

Avoid deeply nested control flow statements.

Open

                    if fn_.endswith(('.py', '.so', '.pyx')):
                        full = salt.utils.url.create(fn_)
                        mod_path = fsclient.cache_file(full, env)
                        if not os.path.isfile(mod_path):
                            continue

Avoid deeply nested control flow statements.

Open

                        if params['nonzero_retcode']:
                            if retcode != 0:
                                continue
                        else:
                            if retcode == 0:

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

Open

    def _master_tops(self):
        '''
        Evaluate master_tops locally
        '''
        if 'id' not in self.opts:

• Read up
  Read up

Avoid deeply nested control flow statements.

Open

                            if self.options.args_separator in arg:
                                sub_args = arg.split(self.options.args_separator)
                                for sub_arg_index, sub_arg in enumerate(sub_args):
                                    if sub_arg:
                                        self.config['arg'][cmd_index].append(sub_arg)

Avoid deeply nested control flow statements.

Open

                            if arg == self.options.args_separator:
                                cmd_index += 1
                                self.config['arg'].append([])
                            else:
                                self.config['arg'][cmd_index].append(arg)

Avoid deeply nested control flow statements.

Open

                    if isinstance(i, dict):
                        expand_variables(i, b, expanded, path + [str(k)])
                    if isinstance(i, six.string_types):

Avoid deeply nested control flow statements.

Open

                    for filename in files:
                        fn = filename[len(file_client.get_cachedir(cache_dest)):].strip('/')
                        tgt = os.path.join(
                                env_root,
                                short,

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

Open

    def format_v0(self, record):
        host = salt.utils.network.get_fqhostname()
        message_dict = {
            '@timestamp': self.formatTime(record),
            '@fields': {

• Read up
  Read up