handle db failure

This commit is contained in:
J. Nick Koston
2023-03-10 08:33:48 -10:00
parent be4891149d
commit 3c39e2ac8c

View File

@@ -211,6 +211,11 @@ class EventTypeManager:
self._id_map[event_type] = db_event_types.event_type_id self._id_map[event_type] = db_event_types.event_type_id
self._pending.clear() self._pending.clear()
def reset(self) -> None:
"""Reset the event manager."""
self._id_map.clear()
self._pending.clear()
class Recorder(threading.Thread): class Recorder(threading.Thread):
"""A threaded recorder class.""" """A threaded recorder class."""
@@ -1201,6 +1206,7 @@ class Recorder(threading.Thread):
self._event_data_ids.clear() self._event_data_ids.clear()
self._pending_state_attributes.clear() self._pending_state_attributes.clear()
self._pending_event_data.clear() self._pending_event_data.clear()
self.event_type_manager.reset()
if not self.event_session: if not self.event_session:
return return