ޠj jSrSSKJr SSKJr SSKJr \(aSSKJr SSK J r J r "SS5r g ) z@Replay state for subgraph checkpoint loading during time-travel.) annotations) TYPE_CHECKING)NS_END)RunnableConfig)BaseCheckpointSaverCheckpointTuplecd\rSrSrSrSrS SjrS SjrS SjrS Sjr Sr g ) ReplayStateaTracks 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. ) checkpoint_id _visited_nsc.Xl[5Ulg)N)r setr )selfr s U/var/www/html/gaurav/venv/lib/python3.13/site-packages/langgraph/_internal/_replay.py__init__ReplayState.__init__s*&)Uc[U;aUR[S5SOUnX R;agURRU5 g)zReturn True the first time a subgraph namespace is seen. The task-id suffix is stripped so that the same logical subgraph (e.g. ``"sub_node"``) is recognized across loop iterations even though each iteration has a different task id. rFT)rrsplitr add)r checkpoint_ns stable_nss r_is_first_visitReplayState._is_first_visit"sS&   +A .  (( ( Y'rcURU5(a)URUSSUR00SS9HnUs $ gURU5$)a$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. configurabler rbeforelimitN)rlistr get_tuplerr checkpointercheckpoint_configsaveds rget_checkpointReplayState.get_checkpoint4sf    . .%**!&$:L:L(MN+   %%&788rc# URU5(a,URUSSUR00SS9ShvN nUs $URU5IShvN $N! gN7f)z"Async version of `get_checkpoint`.rr rrN)ralistr aget_tupler$s raget_checkpointReplayState.aget_checkpointKsy    . .+11!&$:L:L(MN 2  e  !,,->???   ?s26A$A AA A$A"A$A  A$)r r N)r strreturnNone)rr/r0bool)rr/r%rr&rr0zCheckpointTuple | None) __name__ __module__ __qualname____firstlineno____doc__ __slots__rrr(r-__static_attributes__rrr r ss 1I+ $99*9* 9 9.@@*@* @ @rr N) r7 __future__rtypingrlanggraph._internal._constantsrlangchain_core.runnablesrlanggraph.checkpoint.baserrr r:rrr@s(F" 17NL@L@r