Skip to content

Commit 2a7ca84

Browse files
committed
fix: force refresh after failover
1 parent ff95b68 commit 2a7ca84

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

aws_advanced_python_wrapper/aurora_connection_tracker_plugin.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -326,7 +326,7 @@ def execute(self, target: object, method_name: str, execute_func: Callable, *arg
326326

327327
def _check_writer_changed(self, need_refresh_host_lists: bool):
328328
if need_refresh_host_lists:
329-
self._plugin_service.refresh_host_list()
329+
self._plugin_service.force_refresh_host_list()
330330

331331
host_info_after_failover = Utils.get_writer(self._plugin_service.all_hosts)
332332
if host_info_after_failover is None:

aws_advanced_python_wrapper/errors.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
1212
# See the License for the specific language governing permissions and
1313
# limitations under the License.
14+
1415
from typing import Optional
1516

1617
from .pep249 import Error

0 commit comments

Comments
 (0)