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

add final flag check in e2e test

This commit is contained in:
Felix Kunde 2021-02-12 10:00:11 +01:00
parent 329ef995cb
commit dfda70cf24
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
e2e/tests/test_e2e.py
View File

@ -820,6 +820,7 @@ class EndToEndTestCase(unittest.TestCase):
''' '''
k8s = self.k8s k8s = self.k8s
cluster_label = 'application=spilo,cluster-name=acid-minimal-cluster' cluster_label = 'application=spilo,cluster-name=acid-minimal-cluster'
flag = "zalando-postgres-operator-rolling-update-required"
# 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")
@ -828,10 +829,10 @@ class EndToEndTestCase(unittest.TestCase):
_, replica_nodes = k8s.get_pg_nodes(cluster_label) _, replica_nodes = k8s.get_pg_nodes(cluster_label)
# rolling update annotation # rolling update annotation
flag = { rolling_update_flag = {
"metadata": { "metadata": {
"annotations": { "annotations": {
"zalando-postgres-operator-rolling-update-required": "true", flag: "true",
} }
} }
} }
@ -847,9 +848,9 @@ class EndToEndTestCase(unittest.TestCase):
try: try:
# patch both pods for rolling update # patch both pods for rolling update
podsList = k8s.api.core_v1.list_namespaced_pod('default', label_selector=cluster_label) podList = k8s.api.core_v1.list_namespaced_pod('default', label_selector=cluster_label)
for pod in podsList.items: for pod in podList.items:
k8s.patch_pod(flag, pod.metadata.name, pod.metadata.namespace) k8s.patch_pod(rolling_update_flag, pod.metadata.name, pod.metadata.namespace)
if pod.metadata.labels.get('spilo-role') == 'replica': if pod.metadata.labels.get('spilo-role') == 'replica':
switchover_target = pod.metadata.name switchover_target = pod.metadata.name
@ -878,6 +879,12 @@ class EndToEndTestCase(unittest.TestCase):
time.sleep(10) time.sleep(10)
self.eventuallyEqual(lambda: k8s.pg_get_status(), "Running", "Expected running cluster after two syncs") self.eventuallyEqual(lambda: k8s.pg_get_status(), "Running", "Expected running cluster after two syncs")
# rolling update should be gone now
podList = k8s.api.core_v1.list_namespaced_pod('default', label_selector=cluster_label)
for pod in podList.items:
self.assertTrue(flag not in pod.metadata.annotations,
"Rolling update flag still present on pod {}".format(pod.metadata.name))
# revert config changes # revert config changes
patch_resync_config = { patch_resync_config = {
"data": { "data": {