Clean up resources used by the recoverable state. If persistence is enabled, this method deregisters the object from PERSIST_STATE events and persists the current state one last time.
(self)
| 119 | return self.current_value |
| 120 | |
| 121 | async def teardown(self) -> None: |
| 122 | """Clean up resources used by the recoverable state. |
| 123 | |
| 124 | If persistence is enabled, this method deregisters the object from PERSIST_STATE events |
| 125 | and persists the current state one last time. |
| 126 | """ |
| 127 | if not self._persistence_enabled: |
| 128 | return |
| 129 | |
| 130 | if self._persistence_enabled is True: |
| 131 | # Import here to avoid circular imports. |
| 132 | from crawlee import service_locator # noqa: PLC0415 |
| 133 | |
| 134 | event_manager = service_locator.get_event_manager() |
| 135 | event_manager.off(event=Event.PERSIST_STATE, listener=self.persist_state) |
| 136 | await self.persist_state() |
| 137 | |
| 138 | @property |
| 139 | def current_value(self) -> TStateModel: |