Class MongoDBSaver

constructor

• new MongoDBSaver(__namedParameters, serde?): MongoDBSaver

• Parameters

  • __namedParameters: MongoDBSaverParams
  • Optional serde: SerializerProtocol

  Returns MongoDBSaver

checkpointCollectionName

checkpointWritesCollectionName

getTuple

• getTuple(config): Promise<undefined | CheckpointTuple>

• Retrieves a checkpoint from the MongoDB database based on the provided config. If the config contains a "checkpoint_id" key, the checkpoint with the matching thread ID and checkpoint ID is retrieved. Otherwise, the latest checkpoint for the given thread ID is retrieved.

  Parameters

  • config: RunnableConfig

  Returns Promise<undefined | CheckpointTuple>

list

• list(config, options?): AsyncGenerator<CheckpointTuple, any, unknown>

• Retrieve a list of checkpoint tuples from the MongoDB database based on the provided config. The checkpoints are ordered by checkpoint ID in descending order (newest first).

  Parameters

  • config: RunnableConfig
  • Optional options: CheckpointListOptions

  Returns AsyncGenerator<CheckpointTuple, any, unknown>

put

• put(config, checkpoint, metadata): Promise<RunnableConfig>

• Saves a checkpoint to the MongoDB database. The checkpoint is associated with the provided config and its parent config (if any).

  Parameters

  • config: RunnableConfig
  • checkpoint: Checkpoint<string, string>
  • metadata: CheckpointMetadata

  Returns Promise<RunnableConfig>

putWrites

• putWrites(config, writes, taskId): Promise<void>

• Saves intermediate writes associated with a checkpoint to the MongoDB database.

  Parameters

  • config: RunnableConfig
  • writes: PendingWrite<string>[]
  • taskId: string

  Returns Promise<void>