diff --git a/libs/langgraph/langgraph/_internal/_queue.py b/libs/langgraph/langgraph/_internal/_queue.py index a7e48c486..b2cc02a77 100644 --- a/libs/langgraph/langgraph/_internal/_queue.py +++ b/libs/langgraph/langgraph/_internal/_queue.py @@ -25,7 +25,7 @@ class AsyncQueue(asyncio.Queue): self._getters.append(getter) try: await getter - except: + except BaseException: getter.cancel() # Just in case getter is not done yet. try: # Clean self._getters from canceled getters.