def _update_slurm_nodes_with_ec2_info()

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


    def _update_slurm_nodes_with_ec2_info(nodes, cluster_instances):
        if cluster_instances:
            ip_to_slurm_node_map = {node.nodeaddr: node for node in nodes}
            for instance in cluster_instances:
                for private_ip in instance.all_private_ips:
                    if private_ip in ip_to_slurm_node_map:
                        slurm_node = ip_to_slurm_node_map.get(private_ip)
                        slurm_node.instance = instance
                        instance.slurm_node = slurm_node
                        break