diff --git a/libs/core/langchain_core/runnables/base.py b/libs/core/langchain_core/runnables/base.py index e5e82756044..1a0c1e74d03 100644 --- a/libs/core/langchain_core/runnables/base.py +++ b/libs/core/langchain_core/runnables/base.py @@ -36,8 +36,8 @@ from typing import ( from typing_extensions import Literal, get_args -from langchain_core.load.dump import dumpd, dumps from langchain_core._api import beta_decorator +from langchain_core.load.dump import dumpd, dumps from langchain_core.load.serializable import Serializable from langchain_core.pydantic_v1 import BaseConfig, BaseModel, Field, create_model from langchain_core.runnables.config import ( @@ -62,6 +62,7 @@ from langchain_core.runnables.utils import ( ConfigurableFieldSpec, Input, Output, + StreamEvent, accepts_config, accepts_context, accepts_run_manager, @@ -71,7 +72,6 @@ from langchain_core.runnables.utils import ( get_lambda_source, get_unique_config_specs, indent_lines_after_first, - StreamEvent, ) from langchain_core.utils.aiter import atee, py_anext from langchain_core.utils.iter import safetee @@ -85,7 +85,7 @@ if TYPE_CHECKING: from langchain_core.runnables.fallbacks import ( RunnableWithFallbacks as RunnableWithFallbacksT, ) - from langchain_core.tracers.log_stream import RunLog, RunLogPatch, LogEntry + from langchain_core.tracers.log_stream import LogEntry, RunLog, RunLogPatch from langchain_core.tracers.root_listeners import Listener @@ -785,13 +785,13 @@ class Runnable(Generic[Input, Output], ABC): Returns: An async stream of events. """ - from langchain_core.tracers.log_stream import ( - RunLog, - ) from langchain_core.runnables.utils import ( _get_standardized_inputs, _get_standardized_outputs, ) + from langchain_core.tracers.log_stream import ( + RunLog, + ) run_log = RunLog(state=None) # type: ignore[arg-type] yielded_start_event = False