langchain.schema.runnable.RunnableLambda

class langchain.schema.runnable.RunnableLambda(func: Callable[[Input], Output])

Bases: Runnable[Input, Output]

Methods

__init__(func)
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])

async abatch(inputs: List[Input], config: Optional[Union[RunnableConfig, List[RunnableConfig]]] = None, *, max_concurrency: Optional[int] = None) → List[Output]

async ainvoke(input: Input, config: Optional[RunnableConfig] = None) → Output

async astream(input: Input, config: Optional[RunnableConfig] = None) → AsyncIterator[Output]

batch(inputs: List[Input], config: Optional[Union[RunnableConfig, List[RunnableConfig]]] = None, *, max_concurrency: Optional[int] = None) → List[Output]

bind(**kwargs: Any) → Runnable[Input, Output]

Bind arguments to a Runnable, returning a new Runnable.

invoke(input: Input, config: Optional[RunnableConfig] = None) → Output

stream(input: Input, config: Optional[RunnableConfig] = None) → Iterator[Output]