def do_dry_run()

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

• 42 lines of code
• 7 McCabe index (conditional complexity)

    def do_dry_run(self):
        """Show what a regular run would do, but don't actually do it."""
        self.index_list.filter_closed()
        self.index_list.filter_by_shards(number_of_shards=self.number_of_shards)
        self.index_list.empty_list_check()
        try:
            index_lists = chunk_index_list(self.index_list.indices)
            for lst in index_lists:
                for idx in lst:  # Shrink can only be done one at a time...
                    target = self._shrink_target(idx)
                    self.pre_shrink_check(idx, dry_run=True)
                    self.loggit.info(
                        'DRY-RUN: Moving shards to shrink node: "%s"',
                        self.shrink_node_name,
                    )
                    msg = (
                        f'DRY-RUN: Shrinking index "{idx}" to "{target}" with '
                        f'settings: {self.settings}, wait_for_active_shards='
                        f'{self.wait_for_active_shards}'
                    )
                    self.loggit.info(msg)
                    if self.post_allocation:
                        submsg = (
                            f"index.routing.allocation."
                            f"{self.post_allocation['allocation_type']}."
                            f"{self.post_allocation['key']}:"
                            f"{self.post_allocation['value']}"
                        )
                        msg = (
                            f'DRY-RUN: Applying post-shrink allocation rule "{submsg}" '
                            f'to index "{target}"'
                        )
                        self.loggit.info(msg)
                    if self.copy_aliases:
                        msg = (
                            f'DRY-RUN: Copy source index aliases '
                            f'"{self.client.indices.get_alias(index=idx)}"'
                        )
                        self.loggit.info(msg)
                    if self.delete_after:
                        self.loggit.info('DRY-RUN: Deleting source index "%s"', idx)
        except Exception as err:
            report_failure(err)