diff --git a/src/langgraph_ephemeral_checkpointer/sweeper.py b/src/langgraph_ephemeral_checkpointer/sweeper.py index 793075e..d5fd5e4 100644 --- a/src/langgraph_ephemeral_checkpointer/sweeper.py +++ b/src/langgraph_ephemeral_checkpointer/sweeper.py @@ -159,7 +159,10 @@ async def stop(self) -> None: async def _loop(self) -> None: assert self._stop_event is not None while True: - await self.asweep() + try: + await self.asweep() + except Exception: + logger.exception("Sweep cycle failed; will retry after interval") try: await asyncio.wait_for( self._stop_event.wait(),