From d2599d99dfc6c94cd8db95fdaf593e63ee4be39a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jan=20Mu=C3=9Fler?= Date: Tue, 27 Oct 2020 13:17:36 +0100 Subject: [PATCH] Fix funciton in wrong class. --- e2e/tests/k8s_api.py | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/e2e/tests/k8s_api.py b/e2e/tests/k8s_api.py index 86be7d0d1..3822728a7 100644 --- a/e2e/tests/k8s_api.py +++ b/e2e/tests/k8s_api.py @@ -53,6 +53,18 @@ class K8s: return master_pod_node, replica_pod_nodes + def get_cluster_nodes(self, cluster_labels='cluster-name=acid-minimal-cluster', namespace='default'): + m = [] + r = [] + podsList = self.api.core_v1.list_namespaced_pod(namespace, label_selector=cluster_labels) + for pod in podsList.items: + if pod.metadata.labels.get('spilo-role') == 'master' and pod.status.phase == 'Running': + m.append(pod.spec.node_name) + elif pod.metadata.labels.get('spilo-role') == 'replica' and pod.status.phase == 'Running': + r.append(pod.spec.node_name) + + return m, r + def wait_for_operator_pod_start(self): self. wait_for_pod_start("name=postgres-operator")