Class ShallowRedisSaver

ShallowRedisSaver - A Redis checkpoint saver that only keeps the latest checkpoint per thread.

This is a memory-optimized variant that:

Only stores the most recent checkpoint for each thread
Stores channel values inline (no separate blob storage)
Automatically cleans up old checkpoints and writes when new ones are added
Reduces storage usage for applications that don't need checkpoint history

Hierarchy (View Summary)

BaseDynamicToolInput
- ShallowRedisSaver

Index

Constructors

Methods

deleteThread end get getTuple list put putWrites fromUrl

Constructors

constructor

new ShallowRedisSaver(client: any, ttlConfig?: TTLConfig): ShallowRedisSaver
Parameters
- client: any
- OptionalttlConfig: TTLConfig
Returns ShallowRedisSaver
Overrides BaseCheckpointSaver.constructor
- Defined in shallow.ts:88

Methods

deleteThread

deleteThread(threadId: string): Promise<void>
Parameters
- threadId: string
Returns Promise<void>
- Defined in shallow.ts:453

end

end(): Promise<void>
Returns Promise<void>
- Defined in shallow.ts:479

get

get(config: RunnableConfig): Promise<any>
Parameters
- config: RunnableConfig
Returns Promise<any>
- Defined in shallow.ts:105

getTuple

getTuple(config: RunnableConfig): Promise<any>
Parameters
- config: RunnableConfig
Returns Promise<any>
- Defined in shallow.ts:188

list

list(
config: null | RunnableConfig<Record<string, any>>,
options?: any,
): AsyncGenerator<CheckpointTuple>
Parameters
- config: null | RunnableConfig<Record<string, any>>
- Optionaloptions: any
Returns AsyncGenerator<CheckpointTuple>
- Defined in shallow.ts:234

put

put(
    config: RunnableConfig,
    checkpoint: Checkpoint,
    metadata: CheckpointMetadata,
    _newVersions: ChannelVersions,
): Promise<RunnableConfig<Record<string, any>>>
Parameters
- config: RunnableConfig
- checkpoint: Checkpoint
- metadata: CheckpointMetadata
- _newVersions: ChannelVersions
Returns Promise<RunnableConfig<Record<string, any>>>
- Defined in shallow.ts:110

putWrites

putWrites(
    config: RunnableConfig,
    writes: PendingWrite[],
    taskId: string,
): Promise<void>
Parameters
- config: RunnableConfig
- writes: PendingWrite[]
- taskId: string
Returns Promise<void>
- Defined in shallow.ts:377

`Static`fromUrl

fromUrl(url: string, ttlConfig?: TTLConfig): Promise<ShallowRedisSaver>
Parameters
- url: string
- OptionalttlConfig: TTLConfig
Returns Promise<ShallowRedisSaver>
- Defined in shallow.ts:94