diff --git a/libs/langchain/langchain/schema/runnable/base.py b/libs/langchain/langchain/schema/runnable/base.py index 5356720df3..e8a18eb219 100644 --- a/libs/langchain/langchain/schema/runnable/base.py +++ b/libs/langchain/langchain/schema/runnable/base.py @@ -537,7 +537,9 @@ class Runnable(Generic[Input, Output], ABC): ) if accepts_run_manager(transformer): kwargs["run_manager"] = run_manager - iterator = transformer(input_for_transform, **kwargs) # type: ignore[call-arg] + iterator = transformer( + input_for_transform, **kwargs + ) # type: ignore[call-arg] for chunk in iterator: yield chunk if final_output_supported: @@ -613,7 +615,9 @@ class Runnable(Generic[Input, Output], ABC): ) if accepts_run_manager(transformer): kwargs["run_manager"] = run_manager - iterator = transformer(input_for_transform, **kwargs) # type: ignore[call-arg] + iterator = transformer( + input_for_transform, **kwargs + ) # type: ignore[call-arg] async for chunk in iterator: yield chunk if final_output_supported: