Tracks which subgraphs have already loaded their pre-replay checkpoint.
During a parent replay, each subgraph's first invocation should restore the checkpoint from before the replay point. Subsequent invocations of the same subgraph (e.g. in a loop) should use normal checkpoint loading so they pick up freshly created checkpoints.
The single ReplayState instance is shared by reference across all derived
configs within one parent execution.
ReplayState(
self,
checkpoint_id: str,
)| Name | Type |
|---|---|
| checkpoint_id | str |
Load the right checkpoint for a subgraph during replay.
On the first call for a given subgraph namespace, returns the latest checkpoint created before the replay point. On subsequent calls (e.g. the same subgraph in a later loop iteration), falls back to normal latest-checkpoint loading.
Async version of get_checkpoint.