Class RunnableSequence<RunInput, RunOutput>

A sequence of runnables, where the output of each is the input of the next.

Example

const promptTemplate = PromptTemplate.fromTemplate(
  "Tell me a joke about {topic}",
);
const chain = RunnableSequence.from([promptTemplate, new ChatOpenAI({})]);
const result = await chain.invoke({ topic: "bears" });

Type Parameters

RunInput = any
RunOutput = any

Hierarchy

Runnable<RunInput, RunOutput>
- RunnableSequence

Index

Constructors

constructor

new RunnableSequence<RunInput, RunOutput>(fields): RunnableSequence<RunInput, RunOutput>
Type Parameters
- RunInput = any
- RunOutput = any
Parameters
- fields: {
      first: Runnable<RunInput, any, BaseCallbackConfig>;
      last: Runnable<any, RunOutput, BaseCallbackConfig>;
      middle?: Runnable<any, any, BaseCallbackConfig>[];
  }
  - first: Runnable<RunInput, any, BaseCallbackConfig>
  - last: Runnable<any, RunOutput, BaseCallbackConfig>
  - Optional middle?: Runnable<any, any, BaseCallbackConfig>[]
Returns RunnableSequence<RunInput, RunOutput>
Overrides Runnable.constructor
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:1024

Properties

`Protected` first

first: Runnable<RunInput, any, BaseCallbackConfig>

`Protected` last

last: Runnable<any, RunOutput, BaseCallbackConfig>

`Protected` middle

middle: Runnable<any, any, BaseCallbackConfig>[] = []

Accessors

steps

get steps(): Runnable<RunInput, any, BaseCallbackConfig>[]
Returns Runnable<RunInput, any, BaseCallbackConfig>[]
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:1036

Methods

batch

batch(inputs, options?, batchOptions?): Promise<RunOutput[]>
Default implementation of batch, which calls invoke N times. Subclasses should override this method if they can batch more efficiently.
Parameters
- inputs: RunInput[]
  
  Array of inputs to each batch call.
- Optional options: Partial<BaseCallbackConfig> | Partial<BaseCallbackConfig>[]
  
  Either a single call options object to apply to each batch call or an array for each call.
- Optional batchOptions: RunnableBatchOptions & {
  returnExceptions?: false;
  }
Returns Promise<RunOutput[]>
An array of RunOutputs, or mixed RunOutputs and errors if batchOptions.returnExceptions is set
Overrides Runnable.batch
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:1078
batch(inputs, options?, batchOptions?): Promise<(Error | RunOutput)[]>
Parameters
- inputs: RunInput[]
- Optional options: Partial<BaseCallbackConfig> | Partial<BaseCallbackConfig>[]
- Optional batchOptions: RunnableBatchOptions & {
  returnExceptions: true;
  }
Returns Promise<(Error | RunOutput)[]>
Overrides Runnable.batch
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:1084
batch(inputs, options?, batchOptions?): Promise<(Error | RunOutput)[]>
Parameters
- inputs: RunInput[]
- Optional options: Partial<BaseCallbackConfig> | Partial<BaseCallbackConfig>[]
- Optional batchOptions: RunnableBatchOptions
Returns Promise<(Error | RunOutput)[]>
Overrides Runnable.batch
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:1090

bind

bind(kwargs): Runnable<RunInput, RunOutput, BaseCallbackConfig>
Bind arguments to a Runnable, returning a new Runnable.
Parameters
- kwargs: Partial<BaseCallbackConfig>
Returns Runnable<RunInput, RunOutput, BaseCallbackConfig>
A new RunnableBinding that, when invoked, will apply the bound args.
Inherited from Runnable.bind
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:67

invoke

invoke(input, options?): Promise<RunOutput>
Parameters
- input: RunInput
- Optional options: BaseCallbackConfig
Returns Promise<RunOutput>
Overrides Runnable.invoke
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:1040

map

map(): Runnable<RunInput[], RunOutput[], BaseCallbackConfig>
Return a new Runnable that maps a list of inputs to a list of outputs, by calling invoke() with each input.

Returns Runnable<RunInput[], RunOutput[], BaseCallbackConfig>
Inherited from Runnable.map
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:78

pipe

pipe<NewRunOutput>(coerceable): RunnableSequence<RunInput, Exclude<NewRunOutput, Error>>
Create a new runnable sequence that runs each individual runnable in series, piping the output of one runnable into another runnable or runnable-like.
Type Parameters
- NewRunOutput
Parameters
- coerceable: RunnableLike<RunOutput, NewRunOutput>
  
  A runnable, function, or object whose values are functions or runnables.
Returns RunnableSequence<RunInput, Exclude<NewRunOutput, Error>>
A new runnable sequence.
Overrides Runnable.pipe
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:1252

stream

stream(input, options?): Promise<IterableReadableStream<RunOutput>>
Stream output in chunks.
Parameters
- input: RunInput
- Optional options: Partial<BaseCallbackConfig>
Returns Promise<IterableReadableStream<RunOutput>>
A readable stream that is also an iterable.
Inherited from Runnable.stream
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:225

streamLog

streamLog(input, options?, streamOptions?): AsyncGenerator<RunLogPatch, any, unknown>
Stream all output from a runnable, as reported to the callback system. This includes all inner runs of LLMs, Retrievers, Tools, etc. Output is streamed as Log objects, which include a list of jsonpatch ops that describe how the state of the run has changed in each step, and the final state of the run. The jsonpatch ops can be applied in order to construct state.
Parameters
- input: RunInput
- Optional options: Partial<BaseCallbackConfig>
- Optional streamOptions: Omit<LogStreamCallbackHandlerInput, "autoClose">
Returns AsyncGenerator<RunLogPatch, any, unknown>
Inherited from Runnable.streamLog
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:507

toJSON

toJSON(): Serialized
Returns Serialized
Inherited from Runnable.toJSON
- Defined in docs/api_refs/langchain/src/load/serializable.ts:148

toJSONNotImplemented

toJSONNotImplemented(): SerializedNotImplemented
Returns SerializedNotImplemented
Inherited from Runnable.toJSONNotImplemented
- Defined in docs/api_refs/langchain/src/load/serializable.ts:222

transform

transform(generator, options): AsyncGenerator<RunOutput, any, unknown>
Default implementation of transform, which buffers input and then calls stream. Subclasses should override this method if they can start producing output while input is still being generated.
Parameters
- generator: AsyncGenerator<RunInput, any, unknown>
- options: Partial<BaseCallbackConfig>
Returns AsyncGenerator<RunOutput, any, unknown>
Inherited from Runnable.transform
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:478

withConfig

withConfig(config): RunnableBinding<RunInput, RunOutput, BaseCallbackConfig>
Bind config to a Runnable, returning a new Runnable.
Parameters
- config: BaseCallbackConfig
  
  New configuration parameters to attach to the new runnable.
Returns RunnableBinding<RunInput, RunOutput, BaseCallbackConfig>
A new RunnableBinding with a config matching what's passed.
Inherited from Runnable.withConfig
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:107

withFallbacks

withFallbacks(fields): RunnableWithFallbacks<RunInput, RunOutput>
Create a new runnable from the current one that will try invoking other passed fallback runnables if the initial invocation fails.
Parameters
- fields: {
  fallbacks: Runnable<RunInput, RunOutput, BaseCallbackConfig>[];
  }
  - fallbacks: Runnable<RunInput, RunOutput, BaseCallbackConfig>[]
    
    Other runnables to call if the runnable errors.
Returns RunnableWithFallbacks<RunInput, RunOutput>
A new RunnableWithFallbacks.
Inherited from Runnable.withFallbacks
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:124

withRetry

withRetry(fields?): RunnableRetry<RunInput, RunOutput, BaseCallbackConfig>
Add retry logic to an existing runnable.
Parameters
- Optional fields: {
  onFailedAttempt?: RunnableRetryFailedAttemptHandler;
  stopAfterAttempt?: number;
  }
  - Optional onFailedAttempt?: RunnableRetryFailedAttemptHandler
  - Optional stopAfterAttempt?: number
Returns RunnableRetry<RunInput, RunOutput, BaseCallbackConfig>
A new RunnableRetry that, when invoked, will retry according to the parameters.
Inherited from Runnable.withRetry
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:88

`Static` from

from<RunInput, RunOutput>(__namedParameters): RunnableSequence<RunInput, Exclude<RunOutput, Error>>
Type Parameters
- RunInput = any
- RunOutput = any
Parameters
- __namedParameters: [RunnableLike<RunInput, any>, ...RunnableLike<any, any>[], RunnableLike<any, RunOutput>]
Returns RunnableSequence<RunInput, Exclude<RunOutput, Error>>
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:1280

`Static` isRunnable

isRunnable(thing): thing is Runnable<any, any, BaseCallbackConfig>
Parameters
- thing: any
Returns thing is Runnable<any, any, BaseCallbackConfig>
Inherited from Runnable.isRunnable
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:557

`Static` isRunnableSequence

isRunnableSequence(thing): thing is RunnableSequence<any, any>
Parameters
- thing: any
Returns thing is RunnableSequence<any, any>
- Defined in docs/api_refs/langchain/src/schema/runnable/base.ts:1275

Class RunnableSequence<RunInput, RunOutput>

Example

Type Parameters

RunInput = any

RunOutput = any

Hierarchy

Index

Constructors

Properties

Accessors

Methods

Constructors

constructor

Type Parameters

RunInput = any

RunOutput = any

Parameters

fields: { first: Runnable<RunInput, any, BaseCallbackConfig>; last: Runnable<any, RunOutput, BaseCallbackConfig>; middle?: Runnable<any, any, BaseCallbackConfig>[]; }

first: Runnable<RunInput, any, BaseCallbackConfig>

last: Runnable<any, RunOutput, BaseCallbackConfig>

Optional middle?: Runnable<any, any, BaseCallbackConfig>[]

Returns RunnableSequence<RunInput, RunOutput>

Properties

Protected first

Protected last

Protected middle

Accessors

steps

Returns Runnable<RunInput, any, BaseCallbackConfig>[]

Methods

batch

Parameters

inputs: RunInput[]

Optional options: Partial<BaseCallbackConfig> | Partial<BaseCallbackConfig>[]

Optional batchOptions: RunnableBatchOptions & { returnExceptions?: false; }

Returns Promise<RunOutput[]>

Parameters

inputs: RunInput[]

Optional options: Partial<BaseCallbackConfig> | Partial<BaseCallbackConfig>[]

Optional batchOptions: RunnableBatchOptions & { returnExceptions: true; }

Returns Promise<(Error | RunOutput)[]>

Parameters

inputs: RunInput[]

Optional options: Partial<BaseCallbackConfig> | Partial<BaseCallbackConfig>[]

Optional batchOptions: RunnableBatchOptions

Returns Promise<(Error | RunOutput)[]>

bind

Parameters

kwargs: Partial<BaseCallbackConfig>

Returns Runnable<RunInput, RunOutput, BaseCallbackConfig>

invoke

Parameters

input: RunInput

Optional options: BaseCallbackConfig

Returns Promise<RunOutput>

map

Returns Runnable<RunInput[], RunOutput[], BaseCallbackConfig>

pipe

Type Parameters

NewRunOutput

Parameters

coerceable: RunnableLike<RunOutput, NewRunOutput>

Returns RunnableSequence<RunInput, Exclude<NewRunOutput, Error>>

stream

Parameters

input: RunInput

Optional options: Partial<BaseCallbackConfig>

Returns Promise<IterableReadableStream<RunOutput>>

streamLog

Parameters

input: RunInput

Optional options: Partial<BaseCallbackConfig>

Optional streamOptions: Omit<LogStreamCallbackHandlerInput, "autoClose">

Returns AsyncGenerator<RunLogPatch, any, unknown>

toJSON

Returns Serialized

toJSONNotImplemented

Returns SerializedNotImplemented

transform

Parameters

fields: {
first: Runnable<RunInput, any, BaseCallbackConfig>;
last: Runnable<any, RunOutput, BaseCallbackConfig>;
middle?: Runnable<any, any, BaseCallbackConfig>[];
}

`Optional` middle?: Runnable<any, any, BaseCallbackConfig>[]

`Protected` first

`Protected` last

`Protected` middle

`Optional` options: Partial<BaseCallbackConfig> | Partial<BaseCallbackConfig>[]

`Optional` batchOptions: RunnableBatchOptions & {
returnExceptions?: false;
}

`Optional` options: Partial<BaseCallbackConfig> | Partial<BaseCallbackConfig>[]

`Optional` batchOptions: RunnableBatchOptions & {
returnExceptions: true;
}

`Optional` options: Partial<BaseCallbackConfig> | Partial<BaseCallbackConfig>[]

`Optional` batchOptions: RunnableBatchOptions

`Optional` options: BaseCallbackConfig

`Optional` options: Partial<BaseCallbackConfig>

`Optional` options: Partial<BaseCallbackConfig>

`Optional` streamOptions: Omit<LogStreamCallbackHandlerInput, "autoClose">

fields: {
fallbacks: Runnable<RunInput, RunOutput, BaseCallbackConfig>[];
}

`Optional` fields: {
onFailedAttempt?: RunnableRetryFailedAttemptHandler;
stopAfterAttempt?: number;
}

`Optional` onFailedAttempt?: RunnableRetryFailedAttemptHandler

`Optional` stopAfterAttempt?: number

`Static` from

`Static` isRunnable

`Static` isRunnableSequence