diff --git a/libs/langchain/langchain/schema/runnable/base.py b/libs/langchain/langchain/schema/runnable/base.py index 3f6148e9494..a4c95c12eed 100644 --- a/libs/langchain/langchain/schema/runnable/base.py +++ b/libs/langchain/langchain/schema/runnable/base.py @@ -1444,6 +1444,8 @@ class RunnableLambda(Runnable[Input, Output]): if hasattr(self, "afunc"): return await self._acall_with_config(self._ainvoke, input, config) else: + # Delegating to super implementation of ainvoke. + # Uses asyncio executor to run the sync version (invoke) return await super().ainvoke(input, config)