From 2ed1793bbd33175747c9b0ad349fd6185c0e9d08 Mon Sep 17 00:00:00 2001
From: "John A. Lotoski" <39752197+johnalotoski@users.noreply.github.com>
Date: Fri, 18 Nov 2022 01:10:32 -0600
Subject: [PATCH] fix: update service on consul token rotation (#2450)

Close #2449
---
 patroni/dcs/consul.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/patroni/dcs/consul.py b/patroni/dcs/consul.py
index 10886c6e..f4965d90 100644
--- a/patroni/dcs/consul.py
+++ b/patroni/dcs/consul.py
@@ -236,6 +236,7 @@ class Consul(AbstractDCS):
         self._service_check_tls_server_name = config.get('service_check_tls_server_name', None)
         if not self._ctl:
             self.create_session()
+        self._previous_loop_token = self._client.token
 
     def retry(self, *args, **kwargs):
         return self._retry.copy()(*args, **kwargs)
@@ -464,6 +465,7 @@ class Consul(AbstractDCS):
         tags = self._service_tags[:]
         tags.append(role)
         self._previous_loop_service_tags = self._service_tags
+        self._previous_loop_token = self._client.token
 
         params = {
             'service_id': '{0}/{1}'.format(self._scope, self._name),
@@ -500,6 +502,7 @@ class Consul(AbstractDCS):
         if (
             force or update or self._register_service != self._previous_loop_register_service
             or self._service_tags != self._previous_loop_service_tags
+            or self._client.token != self._previous_loop_token
         ):
             return self._update_service(new_data)