langchain.schema.runnable.Runnable¶
class langchain.schema.runnable.Runnable[source]¶
Methods
__init__()
abatch(inputs[, config, max_concurrency])
ainvoke(input[, config])
astream(input[, config])
batch(inputs[, config, max_concurrency])
bind(**kwargs)
Bind arguments to a Runnable, returning a new Runnable.
invoke(input[, config])
stream(input[, config])
with_fallbacks(fallbacks, *[, ...])
__init__()¶
async abatch(inputs: List[Input], config: Optional[Union[RunnableConfig, List[RunnableConfig]]] = None, *, max_concurrency: Optional[int] = None) → List[Output][source]¶
async ainvoke(input: Input, config: Optional[RunnableConfig] = None) → Output[source]¶
async astream(input: Input, config: Optional[RunnableConfig] = None) → AsyncIterator[Output][source]¶
batch(inputs: List[Input], config: Optional[Union[RunnableConfig, List[RunnableConfig]]] = None, *, max_concurrency: Optional[int] = None) → List[Output][source]¶
bind(**kwargs: Any) → Runnable[Input, Output][source]¶
Bind arguments to a Runnable, returning a new Runnable.
abstract invoke(input: Input, config: Optional[RunnableConfig] = None) → Output[source]¶
stream(input: Input, config: Optional[RunnableConfig] = None) → Iterator[Output][source]¶