def find_node()

in eksupdate/src/k8s_client.py [0:0]

• 30 lines of code
• 11 McCabe index (conditional complexity)

def find_node(cluster_name, instance_id,op,regionName):
    ''' finding the node with instance id'''
    loading_config(cluster_name,regionName)
    v1 = client.CoreV1Api()
    nodes = []
    response = v1.list_node()
    if len(response.items)==0:
        return "NAN"
    for node in response.items:
        # print(node.spec.provider_id, node.metadata.name,
        #       node.status.node_info.kube_proxy_version, node.status.node_info.kubelet_version)
        # print(node.status.node_info.os_image)
        nodes.append([node.spec.provider_id.split("/")[-1], node.metadata.name,
                     node.status.node_info.kube_proxy_version.split("-")[0], node.status.node_info.kubelet_version.split("-")[0],node.status.node_info.os_image])
    if op=="find":
        for i in nodes:
            if i[0] == instance_id:
                return i[1]
        return "NAN"
    if op=="os_type":
        for i in nodes:
            if i[0]==instance_id:
                print(i[0])
                return i[-1]
        return "NAN"
    # for node in nodes:
    #     try:
    #         drain_nodes(node[1])
    #     except Exception as x:
    #         return x