in eksupdate/src/k8s_client.py [0:0]
def sort_pods(cluster_name,regionName,original_name,pod_name,old_pods_name,nameSpace,c=90):
if c ==0:
raise Exception("Pod has No assosicated New Launch")
pods_nodes=[]
loading_config(cluster_name,regionName)
v1 = client.CoreV1Api()
try:
if pod_name=="cluster-autoscaler":
pod_list=v1.list_namespaced_pod(namespace=nameSpace, label_selector='app={name}'.format(name=pod_name))
else:
pod_list=v1.list_namespaced_pod(namespace=nameSpace, label_selector='k8s-app={name}'.format(name=pod_name))
except Exception as e:
logs_pusher(regionName,cluster_name,e)
return "Not Found"
print("Total Pods With {p} = {c}".format(p=pod_name,c=len(pod_list.items)))
for i in pod_list.items:
pods_nodes.append([i.metadata.name,i.metadata.creation_timestamp])
if len(pods_nodes)>0:
new_pod_name=sorted(pods_nodes,key=lambda x: x[1])[-1][0]
else:
c-=1
sort_pods(cluster_name,regionName,original_name,pod_name,old_pods_name,nameSpace,c)
''' aws-node not in aws-node-hshsh '''
if original_name != new_pod_name and new_pod_name in old_pods_name:
c-=1
sort_pods(cluster_name,regionName,original_name,pod_name,old_pods_name,nameSpace,c)
return new_pod_name