def _get_terminate_config()

in src/slurm_plugin/clustermgtd.py [0:0]

• 28 lines of code
• 1 McCabe index (conditional complexity)

    def _get_terminate_config(self, config):
        """Get config option related to instance termination and node replacement."""
        self.terminate_max_batch_size = config.getint(
            "clustermgtd", "terminate_max_batch_size", fallback=self.DEFAULTS.get("terminate_max_batch_size")
        )
        self.node_replacement_timeout = config.getint(
            "clustermgtd", "node_replacement_timeout", fallback=self.DEFAULTS.get("node_replacement_timeout")
        )
        self.terminate_drain_nodes = config.getboolean(
            "clustermgtd", "terminate_drain_nodes", fallback=self.DEFAULTS.get("terminate_drain_nodes")
        )
        self.terminate_down_nodes = config.getboolean(
            "clustermgtd", "terminate_down_nodes", fallback=self.DEFAULTS.get("terminate_down_nodes")
        )
        self.orphaned_instance_timeout = config.getint(
            "clustermgtd", "orphaned_instance_timeout", fallback=self.DEFAULTS.get("orphaned_instance_timeout")
        )
        self.protected_failure_count = config.getint(
            "clustermgtd", "protected_failure_count", fallback=self.DEFAULTS.get("protected_failure_count")
        )
        self.insufficient_capacity_timeout = config.getfloat(
            "clustermgtd", "insufficient_capacity_timeout", fallback=self.DEFAULTS.get("insufficient_capacity_timeout")
        )
        self.ec2_instance_missing_max_count = config.getint(
            "clustermgtd",
            "ec2_instance_missing_max_count",
            fallback=self.DEFAULTS.get("ec2_instance_missing_max_count"),
        )
        self.disable_nodes_on_insufficient_capacity = self.insufficient_capacity_timeout > 0