File tree Expand file tree Collapse file tree 1 file changed +10
-0
lines changed Expand file tree Collapse file tree 1 file changed +10
-0
lines changed Original file line number Diff line number Diff line change @@ -81,6 +81,9 @@ def __init__(self, *args):
81
81
self .framework .observe (
82
82
getattr (self .database .on , "endpoints_changed" ), self ._on_endpoints_changed
83
83
)
84
+ self .framework .observe (
85
+ self .on [DATABASE_RELATION ].relation_changed , self ._on_relation_changed
86
+ )
84
87
self .framework .observe (
85
88
self .on [DATABASE_RELATION ].relation_broken , self ._on_relation_broken
86
89
)
@@ -329,6 +332,13 @@ def _on_peer_relation_changed(self, _) -> None:
329
332
330
333
self .unit .status = ActiveStatus ()
331
334
335
+ def _on_relation_changed (self , _ ) -> None :
336
+ """Handle the database relation broken event."""
337
+ if self ._database_config :
338
+ self .unit .status = ActiveStatus ()
339
+ else :
340
+ self .unit .status = WaitingStatus ()
341
+
332
342
def _on_relation_broken (self , _ ) -> None :
333
343
"""Handle the database relation broken event."""
334
344
self ._stop_continuous_writes ()
You can’t perform that action at this time.
0 commit comments