Reset the KVS where the pool state is persisted.
(self)
| 223 | return session |
| 224 | |
| 225 | async def reset_store(self) -> None: |
| 226 | """Reset the KVS where the pool state is persisted.""" |
| 227 | await self._state.reset() |
| 228 | |
| 229 | async def _create_new_session(self) -> Session: |
| 230 | """Create a new session, add it to the pool and return it.""" |