restart on endpoint change

canonical · Sep 12, 2024 · fffd50c · fffd50c
1 parent 61a25a0
commit fffd50c
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/charm.py b/src/charm.py
@@ -348,6 +348,12 @@ def _on_database_created(self, _) -> None:
 
     def _on_endpoints_changed(self, _) -> None:
         """Handle the database endpoints changed event."""
+        if self.is_writes_running:
+            logger.debug("Restarting continuous writes due to endpoints change")
+            self._stop_continuous_writes()
+            self._on_start_continuous_writes_action(None)
+            return
+
         if self.config["auto_start_writes"]:
             count = self._max_written_value()
             self._start_continuous_writes(count + 1)