public_git
/
postgres-operator
mirror of https://github.com/zalando/postgres-operator.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

add wait_for_pod_failover for e2e test

This commit is contained in:
Felix Kunde 2021-02-05 09:49:21 +01:00
parent b892dc49b8
commit 2e57d553f9
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
e2e/tests/test_e2e.py
View File

@ -770,6 +770,9 @@ class EndToEndTestCase(unittest.TestCase):
# verify we are in good state from potential previous tests # verify we are in good state from potential previous tests
self.eventuallyEqual(lambda: k8s.count_running_pods(), 2, "No 2 pods running") self.eventuallyEqual(lambda: k8s.count_running_pods(), 2, "No 2 pods running")
# get nodes of master and replica(s) (expected target of new master)
_, replica_nodes = k8s.get_pg_nodes(cluster_label)
# rolling update annotation # rolling update annotation
flag = { flag = {
"metadata": { "metadata": {
@ -791,8 +794,9 @@ class EndToEndTestCase(unittest.TestCase):
# do not wait until the next sync # do not wait until the next sync
k8s.delete_operator_pod() k8s.delete_operator_pod()
# wait for the both pods to be up and running # operator should now recreate the master pod and do a switchover before
self.eventuallyEqual(lambda: k8s.count_running_pods(), 2, "No 2 pods running") k8s.wait_for_pod_failover(replica_nodes, 'spilo-role=master,' + cluster_label)
k8s.wait_for_pod_start('spilo-role=replica,' + cluster_label)
# check if the former replica is now the new master # check if the former replica is now the new master
leader = k8s.get_cluster_leader_pod('acid-minimal-cluster') leader = k8s.get_cluster_leader_pod('acid-minimal-cluster')