re-write condition in get_spilo_nodes

This commit is contained in:
Sergey Dudoladov 2019-05-31 17:46:20 +02:00
parent 11f2a66f49
commit 8e16e3267d
1 changed files with 2 additions and 2 deletions

View File

@ -254,9 +254,9 @@ class K8s:
replica_pod_nodes = []
podsList = self.api.core_v1.list_namespaced_pod(namespace, label_selector=pod_labels)
for pod in podsList.items:
if ('spilo-role', 'master') in pod.metadata.labels.items():
if pod.metadata.labels.get('spilo-role') == 'master':
master_pod_node = pod.spec.node_name
elif ('spilo-role', 'replica') in pod.metadata.labels.items():
elif pod.metadata.labels.get('spilo-role') == 'replica':
replica_pod_nodes.append(pod.spec.node_name)
return master_pod_node, replica_pod_nodes