ޠj0SSKJr SSKrSSKJrJrJr SSKJrJr SSK J r J r SSK J r SSKJrJr SSKJr SS KJr SS KJr SS KJr SS KJr SS KJr SSKJr SSKJ r J!r! Sr"\\ S/\ 4r#SSjr$S Sjr%S!Sjr&S"Sjr'S#Sjr(S$Sjr)S%Sjr*SSSSS.S&Sjjr+S'Sjr,SSS.S(Sjjr-SSS.S(Sjjr.S)Sjr/g)*) annotationsN)CallableIterableMapping)datetimetimezone)Anycast)RunnableConfig)BaseCheckpointSaver Checkpoint)uuid6)_DeltaSnapshot)#DELTA_MAX_SUPERSTEPS_SINCE_SNAPSHOT)PUSH)MISSING) BaseChannel) DeltaChannel)ManagedValueMappingManagedValueSpecc [[[[SS95[R "[ R5R5000S9$)N clock_seq)vidtschannel_valueschannel_versions versions_seen) r LATEST_VERSIONstrrrnowrutc isoformatV/var/www/html/gaurav/venv/lib/python3.13/site-packages/langgraph/pregel/_checkpoint.pyempty_checkpointr*sA   ur" # << % / / 1  r(c [[R"U55RS5nUSSUSSUSSUSSUS3 $)zSynthetic task id for exit-mode DeltaChannel writes. Embeds the superstep in the first UUID group so `ORDER BY task_id, idx` preserves chronological order while remaining a valid RFC UUID (required by Postgres `checkpoint_writes.task_id uuid` columns). -08dr)r#uuidUUIDsplit)steptask_idpartss r)exit_delta_task_idr7'sW  '" # ) )# .E3Zqq !E!H:QuQxj%( DDr(c$[5nUR5Hqup4[U[5(aUR 5(dM1UR US5upVXTR :d U[:dM`URU5 Ms U$)u#Return the set of DeltaChannel names that should snapshot now. A channel snapshots when EITHER its accumulated update count reaches `snapshot_frequency` OR the total supersteps since its last snapshot reaches `DELTA_MAX_SUPERSTEPS_SINCE_SNAPSHOT`. This is a pure predicate — no mutation. rr) setitems isinstancer is_availablegetsnapshot_frequencyradd)channelscounters_since_delta_snapshotresultnamechupdates superstepss r)delta_channels_to_snapshotrH2swuFNN$"l++2??3D3D ;??fM ,, ,@@ JJt % Mr(c|UVVVs1sH%oRHup#U[:wdMUiM M' snnn$s snnnf)zDChannel names written by an update_state superstep (excluding PUSH).)writesr) run_taskstaskc_s r)get_updated_channels_from_tasksrOJs.$ I)$ qDyA A) II Is7 7cUR5VVs1sH5up[U[5(dMUR5(dM3UiM7 snn$s snnf)zFDeltaChannels to snapshot on the first update_state of a fresh thread.)r;r<rr=)rAkrEs r)$get_delta_channels_from_all_channelsrRQsK ^^% %EA b, ' ,.OO,= %  sAA Ac[U=(d 0RS5=(d 05n0nUR5HDupV[U[5(dMURUS5upxUS- nXQ;aUS- nXx4XE'MF U$)zAdvance ``counters_since_delta_snapshot`` for update_state on a non-fresh thread. Mirrors the per-superstep counter bump in ``_loop._put_checkpoint``. rBr9r.)dictr>r;r<r) rAupdated_channels prev_metadata prev_counters new_countersch_namerEuss r)$create_metadata_for_update_state_apir\\s  "!!"ABHbM02L~~' "l++   &1 Q  & FA!" ( r(cSUUS.nU(a [U5U4$[UUUS9n[X5nUHn SXy'M UR5V V s0sHupU S:wdM X_M n n n U (aXS'X4$s sn n f)zEReturn ``(channels_to_snapshot, metadata)`` for an update_state head.update)sourcer4parents)rVr9rB)rRr\rHr;) rArUr4r`saved_metadatais_fresh_threadmetadatarXchannels_to_snapshotrQrnon_zeros r)+create_checkpoint_plan_for_update_state_apirfus H 3H=xGG7$L 6hM ! "!-!3!3!5E!5f!5HE4<01  ))Fs  A7 A7)rrUget_next_versionrdc  [R"[R5R 5nU=(d [ 5nUc USnUSn O}0n[ US5n UHgn X;aM Xn X;a5UbUbX;a U"XS5X'[U R55X'MHU R5n U [LdMcXU 'Mi [[UU=(d [[US95UU USUcSS9$[U5S9$)uBuild a new Checkpoint from the previous one and live channel state. For each name in `channels_to_snapshot`, a `_DeltaSnapshot(value)` blob is written into `channel_values[k]`. Other delta channels are omitted from `channel_values` — the ancestor walk reconstructs their state from `checkpoint_writes`. Callers compute the set via `delta_channels_to_snapshot(channels, counters)`; defaults to empty (no snapshots) when not provided. Nrr rr!rrrrr r!rU)rr$rr%r&r:rTrr> checkpointrr r"r#rsorted) rjrAr4rrUrgrdrvaluesr rQrErs r)create_checkpointrms'& hll # - - /B/835,-%&89 += >?A(B("$/$,0I*:;K;NPT*U$'*26684 MMOG# !1I;<   +UT*+) 1!1!9 @FFV?W r(c>[U[5(dgU[L$)uTrue if `spec` is a `DeltaChannel` and no value is stored at this checkpoint, requiring an ancestor walk to reconstruct. `_DeltaSnapshot` blobs and plain values (migration) resolve directly via `from_checkpoint` — only absence (`MISSING`) triggers replay. F)r<rr)specstoreds r) _needs_replayrqs dL ) ) W r()saverconfigc 0n0nUR5H$upg[U[5(aXtU'M XuU'M& UR5VVs/sH0uph[XSR U[ 55(dM.UPM2 n nn0n U (aUbUbUR X9S9n 0n UR5HuphXj;aP[[U5n Xn U RU R S[ 55nURU S5 UnO(URUSR U[ 55nXU'M X4$s snnf)aHydrate channels from a checkpoint. For most channels, `spec.from_checkpoint(checkpoint["channel_values"][k])` is sufficient. `DeltaChannel` is the exception: when the channel is absent from `channel_values`, an ancestor walk via `saver.get_delta_channel_history` is required to find the nearest seed (`_DeltaSnapshot` blob or pre-migration plain value) and accumulate the writes between it and the target. All delta channels needing replay are batched into a single saver call. rrsrAseedrJ) r;r<rrqr>rget_delta_channel_historyr rfrom_checkpoint replay_writesspecsrjrrrs channel_specs managed_specsrQrrodelta_channels historiesrA delta_spechistory replay_chrEs r)channels_from_checkpointrsR"-/M13M  a % % !  !  %**,!,GA *:;??7K L ,! $&I%+0B334 (*H &&( >lD1JlG"227;;vw3OPI  # #GH$5 6B%%j1A&B&F&Fq'&RSB )  ""/!s ,EEc # 0n0nUR5H$upg[U[5(aXtU'M XuU'M& UR5VVs/sH0uph[XSR U[ 55(dM.UPM2 n nn0n U (aUbUbUR X9S9IShvN n 0n UR5HuphXj;aP[[U5n Xn U RU R S[ 55nURU S5 UnO(URUSR U[ 55nXU'M X4$s snnfN7f)zAAsync version of `channels_from_checkpoint`. See docstring there.rNrurvrJ) r;r<rrqr>raget_delta_channel_historyr rrxryrzs r)achannels_from_checkpointrs_-/M13M  a % % !  !  %**,!,GA *:;??7K L ,! $&I%+0B::;  (*H &&( >lD1JlG"227;;vw3OPI  # #GH$5 6B%%j1A&B&F&Fq'&RSB )  ""/! s%AE,EE$E,E-B*Ec[USUSUSUSR5USR5USR5VVs0sHupXR5_M snnURSS5S9$s snnf) Nrrrrr r!rUri)r copyr;r>)rjrQrs r)copy_checkpointrBs  S/ d  d !"2388:#$67<<>/9//J/P/P/RS/Rtqq&&({/RS#(:DA  Ts A>)returnr )r4intr5r#rr#)rAMapping[str, BaseChannel]rBzMapping[str, tuple[int, int]]rset[str])rKz Iterable[Any]rr)rArrr)rArrUrrVMapping[str, Any] | Nonerzdict[str, tuple[int, int]])rArrUrr4rr`zdict[str, Any]rarrbboolrztuple[set[str], dict[str, Any]])rjr rAz Mapping[str, BaseChannel] | Noner4rrz str | NonerUset[str] | NonergzGetNextVersion | Nonerdrrr )rorrpobjectrr) r{z,Mapping[str, BaseChannel | ManagedValueSpec]rjr rrzBaseCheckpointSaver | NonerszRunnableConfig | Nonerz5tuple[Mapping[str, BaseChannel], ManagedValueMapping])rjr rr )0 __future__rr1collections.abcrrrrrtypingr r langchain_core.runnablesr langgraph.checkpoint.baser r langgraph.checkpoint.base.idr langgraph.checkpoint.serde.typesrlanggraph._internal._configrlanggraph._internal._constantsrlanggraph._internal._typingrlanggraph.channels.baserlanggraph.channels.deltarlanggraph.managed.baserrr"GetNextVersionr*r7rHrOrRr\rfrmrqrrrr'r(r)rs" 77'3/;K///1H3+s*+E'#@0JJ J' ',   2*'**  *  * - **%*J(,.2,0AA.A A  A & A,A*AAH  )-$( 0# 70#0# & 0# " 0# ; 0#n)-$( '# 7'#'# & '# " '# ; '#T r(