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

delete replica pod for lazy update test

This commit is contained in:
Felix Kunde 2020-04-17 15:32:50 +02:00
parent 2ae6d34cbb
commit 7a1f16f9a8
1 changed files with 16 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
e2e/tests/test_e2e.py
View File

@ -142,15 +142,6 @@ class EndToEndTestCase(unittest.TestCase):
}) })
k8s.wait_for_pods_to_stop(pod_selector) k8s.wait_for_pods_to_stop(pod_selector)
k8s.api.custom_objects_api.patch_namespaced_custom_object(
'acid.zalan.do', 'v1', 'default',
'postgresqls', 'acid-minimal-cluster',
{
'spec': {
'enableConnectionPooler': True,
}
})
k8s.wait_for_pod_start(pod_selector)
except timeout_decorator.TimeoutError: except timeout_decorator.TimeoutError:
print('Operator log: {}'.format(k8s.get_operator_log())) print('Operator log: {}'.format(k8s.get_operator_log()))
raise raise
@ -217,11 +208,12 @@ class EndToEndTestCase(unittest.TestCase):
''' '''
k8s = self.k8s k8s = self.k8s
pod0 = "acid-minimal-cluster-0" master_pod = ""
pod1 = "acid-minimal-cluster-1" replica_pod = ""
cluster_label = 'application=spilo,cluster-name=acid-minimal-cluster'
# enable lazy update # enable lazy update
conf_image = "registry.opensource.zalan.do/acid/spilo-cdp-12:1.6-p112" conf_image = "registry.opensource.zalan.do/acid/spilo-cdp-12:1.6-p111"
patch_lazy_spilo_upgrade = { patch_lazy_spilo_upgrade = {
"data": { "data": {
"enable_lazy_spilo_upgrade": "true", "enable_lazy_spilo_upgrade": "true",
@ -231,17 +223,23 @@ class EndToEndTestCase(unittest.TestCase):
k8s.update_config(patch_lazy_spilo_upgrade) k8s.update_config(patch_lazy_spilo_upgrade)
# restart the pod to get a container with the new image # restart the pod to get a container with the new image
k8s.api.core_v1.delete_namespaced_pod(pod0, "default") podsList = self.api.core_v1.list_namespaced_pod(namespace, label_selector=pg_cluster_name)
k8s.wait_for_running_pods('cluster-name=acid-minimal-cluster', 2) for pod in podsList.items:
if pod.metadata.labels.get('spilo-role') == 'master':
master_pod = pod.metadata.name
elif pod.metadata.labels.get('spilo-role') == 'replica':
k8s.api.core_v1.delete_namespaced_pod(pod, "default")
k8s.wait_for_pod_start('spilo-role=replica')
replica_pod = pod.metadata.name
# sanity check: restarted pod runs the image specified in operator's conf # sanity check: restarted pod runs the image specified in operator's conf
new_image = k8s.get_effective_pod_image(pod0) new_image = k8s.get_effective_pod_image(replica_pod)
self.assertEqual(conf_image, new_image, self.assertEqual(conf_image, new_image,
"Lazy upgrade failed: restarted pod runs image {} different from the one in operator conf {}".format(new_image, conf_image)) "Lazy upgrade failed: restarted pod runs image {} different from the one in operator conf {}".format(new_image, conf_image))
# lazy update works if the restarted pod and older pods have different Spilo versions # lazy update works if the restarted pod and older pods have different Spilo versions
# i.e. the update did not immediately affect all pods # i.e. the update did not immediately affect all pods
old_image = k8s.get_effective_pod_image(pod1) old_image = k8s.get_effective_pod_image(master_pod)
self.assertNotEqual(old_image, new_image, "Lazy updated failed: pods have the same image {}".format(new_image)) self.assertNotEqual(old_image, new_image, "Lazy updated failed: pods have the same image {}".format(new_image))
# clean up # clean up
@ -257,8 +255,8 @@ class EndToEndTestCase(unittest.TestCase):
# XXX there is no easy way to wait until the end of Sync() # XXX there is no easy way to wait until the end of Sync()
time.sleep(60) time.sleep(60)
image0 = k8s.get_effective_pod_image(pod0) image0 = k8s.get_effective_pod_image(replica_pod)
image1 = k8s.get_effective_pod_image(pod1) image1 = k8s.get_effective_pod_image(master_pod)
self.assertEqual(image0, image1, "Disabling lazy upgrade failed: pods still have different images {} and {}".format(image0, image1)) self.assertEqual(image0, image1, "Disabling lazy upgrade failed: pods still have different images {} and {}".format(image0, image1))