We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6e15799 commit 4bf288fCopy full SHA for 4bf288f
1 file changed
src/crawlee/events/_event_manager.py
@@ -133,12 +133,14 @@ async def __aexit__(
133
134
self._ref_count -= 1
135
136
+ # Emit persist state event to ensure the latest state is saved before closing the context.
137
+ await self._emit_persist_state_event()
138
+
139
if self._ref_count > 0:
140
return
141
142
# Stop persist state event periodic emission and manually emit last one to ensure latest state is saved.
143
await self._emit_persist_state_event_rec_task.stop()
- await self._emit_persist_state_event()
144
await self.wait_for_all_listeners_to_complete(timeout=self._close_timeout)
145
self._event_emitter.remove_all_listeners()
146
self._listener_tasks.clear()
0 commit comments