def debug_completed_nodes()

in hostfactory/host_provider/src/cyclecloud_provider.py [0:0]

• 12 lines of code
• 4 McCabe index (conditional complexity)

    def debug_completed_nodes(self):
        all_nodes = self.cluster.all_nodes()
        actual_completed_nodes = set()
        for node in all_nodes['nodes']:
            if node.get("Status") in ["Ready", "Started"]:
                actual_completed_nodes.add(node.get("NodeId"))
        internal_completed_nodes = set()
        with self.creation_json as request_store:
            for request in request_store.values():
                internal_completed_nodes.update(set(request.get("completedNodes")))
        incomplete_nodes = actual_completed_nodes - internal_completed_nodes
        print(incomplete_nodes)