def clean_hosts()

in gridengine/src/gridengine/driver.py [0:0]

• 21 lines of code
• 6 McCabe index (conditional complexity)

    def clean_hosts(self, invalid_nodes: List[SchedulerNode]) -> List[Node]:
        logging.getLogger("gridengine.driver").info("clean_hosts")

        filtered = []

        for node in invalid_nodes:
            if node.keep_alive:
                logging.fine("Not removing %s because keep_alive=true", node)
                continue
            if not node.resources.get("ccnodeid"):
                logging.fine(
                    "Not removing %s because it does not define ccnodeid", node
                )
                continue
            filtered.append(node)

        if not filtered:
            return []

        logging.warning(
            "Cleaning out the following hosts in state=au: %s",
            [str(x) for x in filtered],
        )
        self.handle_post_delete(filtered)

        return filtered