Store intermediate writes linked to a checkpoint.
This method saves intermediate writes associated with a checkpoint to the Postgres database.
putWrites(
config: RunnableConfig,
writes: PendingWrite[],
taskId: string
): Promise<void>| Name | Type | Description |
|---|---|---|
config* | RunnableConfig | Configuration of the related checkpoint. |
writes* | PendingWrite[] | List of writes to store. |
taskId* | string | Identifier for the task creating the writes. |