def do_action()

in curator/actions/close.py [0:0]

• 31 lines of code
• 8 McCabe index (conditional complexity)

    def do_action(self):
        """
        :py:meth:`~.elasticsearch.client.IndicesClient.close` open indices in
        :py:attr:`index_list`
        """
        self.index_list.filter_closed()
        self.index_list.empty_list_check()
        self.loggit.info(
            'Closing %s selected indices: %s',
            len(self.index_list.indices),
            self.index_list.indices,
        )
        try:
            index_lists = chunk_index_list(self.index_list.indices)
            for lst in index_lists:
                lst_as_csv = to_csv(lst)
                self.loggit.debug('CSV list of indices to close:  %s', lst_as_csv)
                if self.delete_aliases:
                    self.loggit.info('Deleting aliases from indices before closing.')
                    self.loggit.debug('Deleting aliases from:  %s', lst)
                    try:
                        self.client.indices.delete_alias(index=lst_as_csv, name='*')
                        self.loggit.debug('Deleted aliases from: %s', lst)
                    # pylint: disable=broad-except
                    except Exception as err:
                        self.loggit.warning(
                            'Some indices may not have had aliases.  Exception: %s', err
                        )
                if not self.skip_flush:
                    self.client.indices.flush(
                        index=lst_as_csv, ignore_unavailable=True, force=True
                    )
                # ElasticsearchWarning: the default value for the
                # wait_for_active_shards parameter will change from '0' to
                # 'index-setting' in version 8;
                # specify 'wait_for_active_shards=index-setting' to adopt the
                # future default behaviour, or
                # 'wait_for_active_shards=0' to preserve today's behaviour
                warnings.filterwarnings("ignore", category=ElasticsearchWarning)
                self.client.indices.close(index=lst_as_csv, ignore_unavailable=True)
        # pylint: disable=broad-except
        except Exception as err:
            report_failure(err)