diff --git a/e2e/tests/test_e2e.py b/e2e/tests/test_e2e.py index 6364fa398..f46c0577e 100644 --- a/e2e/tests/test_e2e.py +++ b/e2e/tests/test_e2e.py @@ -724,9 +724,6 @@ class K8s: stdout=subprocess.PIPE, stderr=subprocess.PIPE) - def get_patroni_state(self, pod): - return pod.metadata.annotations["status"]["state"] - if __name__ == '__main__': unittest.main() diff --git a/pkg/util/patroni/patroni.go b/pkg/util/patroni/patroni.go index 008dc3e58..53065e599 100644 --- a/pkg/util/patroni/patroni.go +++ b/pkg/util/patroni/patroni.go @@ -126,7 +126,7 @@ func (p *Patroni) SetPostgresParameters(server *v1.Pod, parameters map[string]st return p.httpPostOrPatch(http.MethodPatch, apiURLString+configPath, buf) } -//GetPatroniMemberState returns node state reported by Patroni API call. +//GetPatroniMemberState returns a state of member of a Patroni cluster func (p *Patroni) GetPatroniMemberState(server *v1.Pod) (string, error) { apiURLString, err := apiURL(server)