fix LocalEventManager

Author: Mantisus

src/crawlee/events/_event_manager.py

@@ -129,6 +129,7 @@ async def __aexit__(
         if self._active_ref_count > 1:
             # Emit persist state event to ensure the latest state is saved before closing the context.
             await self._emit_persist_state_event()
+            await self.wait_for_all_listeners_to_complete(timeout=self._close_timeout)
             self._active_ref_count -= 1
             return
 

src/crawlee/events/_local_event_manager.py

@@ -75,7 +75,10 @@ async def __aenter__(self) -> LocalEventManager:
         It starts emitting system info events at regular intervals.
         """
         await super().__aenter__()
-        self._emit_system_info_event_rec_task.start()
+
+        if self._active_ref_count == 1:
+            self._emit_system_info_event_rec_task.start()
+
         return self
 
     async def __aexit__(
@@ -88,7 +91,9 @@ async def __aexit__(
 
         It stops emitting system info events and closes the event manager.
         """
-        await self._emit_system_info_event_rec_task.stop()
+        if self._active_ref_count == 1:
+            await self._emit_system_info_event_rec_task.stop()
+
         await super().__aexit__(exc_type, exc_value, exc_traceback)
 
     async def _emit_system_info_event(self) -> None: