Method●Since v0.8

put_writes

Store pending writes for fault tolerance.

Creates PendingWrite nodes and links them to the Checkpoint via HAS_WRITE relationships.

put_writes(
  self,
  config: RunnableConfig,
  writes: Sequence[tuple[str, Any]],
  task_id: str,
  task_path: str = ''
) -> None

Parameters

Name	Type	Description
`config`*	`RunnableConfig`	The runnable configuration.
`writes`*	`Sequence[tuple[str, Any]]`	Sequence of (channel, value) tuples to store.
`task_id`*	`str`	Identifier for the task that produced these writes.
`task_path`	`str`	Default:`''` Path information for the task (default: "").