Skip to content

Commit 4c12ed0

Browse files
committed
Clears state backend caches on destroy
1 parent 576b9c9 commit 4c12ed0

1 file changed

Lines changed: 7 additions & 0 deletions

File tree

plugboard/state/sqlite_state_backend.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,13 @@ async def init(self) -> None:
5151
await self._initialise_db()
5252
await super().init()
5353

54+
async def destroy(self) -> None:
55+
"""Destroys the `SqliteStateBackend`."""
56+
await super().destroy()
57+
self._get_db_id.cache_clear()
58+
self._get_process_id_for_component.cache_clear()
59+
self._get_process_id_for_connector.cache_clear()
60+
5461
async def _fetchone(
5562
self, statement: str, params: _t.Tuple[_t.Any, ...]
5663
) -> aiosqlite.Row | None:

0 commit comments

Comments
 (0)