§
    šŠtj¥@ ã                  óÔ  — d dl mZ d dlZd dlZd dlZd dlmZmZ d dl	m
Z
mZmZmZ d dlmZmZmZmZ d dlmZmZ d dlmZ d dlmZ d d	lmZmZmZmZ d d
lmZm Z  d dl!m"Z" d dl#m$Z$ d dl%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z, d dl-m.Z. d dl/m0Z0m1Z1 d dl2m3Z3 d dl4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJ d dlKmLZL d dlMmNZN d dlOmPZPmQZQ d dlRmSZSmTZTmUZU d dlVmWZW d dlXmYZY d dlZm[Z[ d dl\m]Z] d dl^m_Z_ d dl`maZambZb d dlcmdZdmeZe d dlfmgZgmhZhmiZimjZjmkZkmlZlmmZmmnZnmoZompZpmqZqmrZr d dlsmtZtmuZumvZvmwZwmxZxmyZymzZz d dl{m|Z|m}Z}m~Z~ d d lm€Z€m�Z�m‚Z‚mƒZƒm„Z„ d d!l…m†Z† d d"l‡mˆZˆ d d#l‰mŠZŠm‹Z‹ d d$lŒm�Z�mŽZŽm�Z� d d%l�m‘Z‘m’Z’ d d&l“m”Z”m•Z• d d'l–m—Z—m˜Z˜m™Z™mšZšm›Z›mœZœm�Z�mžZžmŸZŸ  ed(¦  «        Z  e0d)¦  «        Z¡ee¢e£ef                  Z¤d4d-„Z¥ G d.„ d/¦  «        Z¦ G d0„ d1e¦e¦  «        Z§ G d2„ d3e¦e¦  «        Z¨dS )5é    )ÚannotationsN)ÚdefaultdictÚdeque)ÚCallableÚIteratorÚMappingÚSequence)ÚAbstractAsyncContextManagerÚAbstractContextManagerÚAsyncExitStackÚ	ExitStack)ÚdatetimeÚtimezone)Ú	signature)ÚTracebackType)ÚAnyÚLiteralÚTypeVarÚcast)ÚAsyncParentRunManagerÚParentRunManager)ÚRunnableConfig)Ú	BaseCache)ÚWRITES_IDX_MAPÚBaseCheckpointSaverÚChannelVersionsÚ
CheckpointÚCheckpointMetadataÚCheckpointTupleÚPendingWrite)Ú	BaseStore)Ú	ParamSpecÚSelf)Úpatch_configurable)ÚCONFÚCONFIG_KEY_CHECKPOINT_IDÚCONFIG_KEY_CHECKPOINT_MAPÚCONFIG_KEY_CHECKPOINT_NSÚCONFIG_KEY_REPLAY_STATEÚCONFIG_KEY_RESUME_MAPÚCONFIG_KEY_RESUMINGÚCONFIG_KEY_RUNTIMEÚCONFIG_KEY_SCRATCHPADÚCONFIG_KEY_STREAMÚCONFIG_KEY_TASK_IDÚCONFIG_KEY_THREAD_IDÚERRORÚERROR_SOURCE_NODEÚINPUTÚ	INTERRUPTÚNS_ENDÚNS_SEPÚNULL_TASK_IDÚPUSHÚRESUMEÚTASKS)ÚReplayState)ÚPregelScratchpad)Ú	EMPTY_SEQÚMISSING)ÚGraphInterruptEventÚGraphLifecycleEventÚGraphResumeEvent)ÚBaseChannel)Ú_get_overwrite)ÚDeltaChannel)ÚUntrackedValue)Ú
TAG_HIDDEN)ÚEmptyInputErrorÚGraphInterrupt)ÚManagedValueMappingÚManagedValueSpec)ÚCallÚGetNextVersionÚPregelTaskWritesÚapply_writesÚcheckpoint_null_versionÚ	incrementÚprepare_next_tasksÚprepare_node_error_handler_taskÚprepare_single_taskÚ!sanitize_untracked_values_in_sendÚshould_interruptÚtask_path_str)Úachannels_from_checkpointÚchannels_from_checkpointÚcopy_checkpointÚcreate_checkpointÚdelta_channels_to_snapshotÚempty_checkpointÚexit_delta_task_id)ÚAsyncBackgroundExecutorÚBackgroundExecutorÚSubmit)Úmap_commandÚ	map_inputÚmap_output_updatesÚmap_output_valuesÚread_channels)Úensure_message_ids)Ú
PregelNode)Úget_new_channel_versionsÚis_xxh3_128_hexdigest)Úmap_debug_checkpointÚmap_debug_task_resultsÚmap_debug_tasks)ÚStreamChunkÚStreamProtocol)Ú
RunControlÚRuntime)	ÚAllÚCachePolicyÚCommandÚ
DurabilityÚ	InterruptÚPregelExecutableTaskÚRetryPolicyÚSendÚ
StreamModeÚVÚPÚstreamsrn   Úreturnc                 óD   ‡ — dˆ fd„}t          |d„ ‰ D ¦   «         ¦  «        S )NÚvaluerm   r}   ÚNonec                óF   •— ‰D ]}| d         |j         v r || ¦  «         Œd S )Né   ©Úmodes)r   Ústreamr|   s     €úT/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/langgraph/pregel/_loop.pyÚ__call__zDuplexStream.<locals>.__call__–   s;   ø€ Øð 	ð 	ˆFØ�QŒx˜6œ<Ð'Ð'Ø��u‘”�øð	ð 	ó    c                ó&   — h | ]}|j         D ]}|’ŒŒS © rƒ   )Ú.0ÚsÚmodes      r†   ú	<setcomp>zDuplexStream.<locals>.<setcomp>›   s'   € Ð$OÐ$OÐ$O¨aÀqÄwÐ$OÐ$O¸t TÐ$OÐ$OÐ$OÐ$Orˆ   )r   rm   r}   r€   )rn   )r|   r‡   s   ` r†   ÚDuplexStreamr�   •   sB   ø€ ðð ð ð ð ð õ
 ˜(Ð$OÐ$O°7Ð$OÑ$OÔ$OÑPÔPÐPrˆ   c                  óæ  — e Zd ZU ded<   ded<   ded<   ded<   ded	<   d
ed<   ded<   ded<   ded<   ded<   ded<   ded<   ded<   ded<   ded<   ded<   ded<   ded<   d ed!<   d"ed#<   d$ed%<   d&ed'<   d(ed)<   ded*<   d+ed,<   d-ed.<   d/ed0<   d1ed2<   d3Zd4ed5<   d3Zd4ed6<   d3Zd7ed8<   d9ed:<   ded;<   d<Zded=<   d>ed?<   d@edA<   dBedC<   dDedE<   dedF<   dGedH<   dIedJ<   dKedL<   dMedN<   dOedP<   dQedR<   dSedT<   d3ZdUedV<   d3Z	dWedX<   dYedZ<   ded[<   e
e
d3d3d\d3d<d]œd de„Zd\dfœd¡dk„Zd¢dm„Zd£dq„Zd¤dr„Z	 d¥d¦dy„Zd§d}„Zd§d~„Zd¨d„Zd¤d€„Zd©d‚„Zd©dƒ„Zdªd…„Zd¤d†„Zd«d‡„Zd¬dˆ„Zd­dŠ„Zd¤d‹„Zd®d“„Zd¯dœ„Zd<d�œd°dŸ„Zd3S )±Ú
PregelLoopr   ÚconfigúBaseStore | NoneÚstoreúStreamProtocol | Noner…   ÚintÚstepÚstopú
Any | NoneÚinputzBaseCache[WritesT] | NoneÚcacheúBaseCheckpointSaver | NoneÚcheckpointerúMapping[str, PregelNode]Únodesú,Mapping[str, BaseChannel | ManagedValueSpec]Úspecsústr | Sequence[str]Ú
input_keysÚoutput_keysÚstream_keysÚboolÚis_replayingÚ	is_nestedú/None | AsyncParentRunManager | ParentRunManagerÚmanagerúAll | Sequence[str]Úinterrupt_afterÚinterrupt_beforert   Ú
durabilityúSequence[RetryPolicy]Úretry_policyúCachePolicy | NoneÚcache_policyrL   Úcheckpointer_get_next_versionz4Callable[[RunnableConfig, WritesT, str], Any] | NoneÚcheckpointer_put_writesÚ)checkpointer_put_writes_accepts_task_pathzjCallable[[concurrent.futures.Future | None, RunnableConfig, Checkpoint, str, ChannelVersions], Any] | NoneÚ _checkpointer_put_after_previousú#Callable[[Checkpoint], None] | NoneÚ_migrate_checkpointr`   ÚsubmitzMapping[str, BaseChannel]ÚchannelsNzlist[Any] | NoneÚ_delta_write_futsÚ_error_handler_write_futsz&list[tuple[int, str, str, Any]] | NoneÚ_exit_delta_writesúset[str]Ú_delta_channels_with_overwriteÚ_initial_checkpoint_configFÚ_has_persisted_parentrI   Úmanagedr   Ú
checkpointÚstrÚcheckpoint_id_savedztuple[str, ...]Úcheckpoint_nsÚcheckpoint_configr   Úcheckpoint_metadatazlist[PendingWrite]Úcheckpoint_pending_writeszdict[str, str | float | int]Úcheckpoint_previous_versionszRunnableConfig | NoneÚprev_checkpoint_configzfLiteral['input', 'pending', 'done', 'draining', 'interrupt_before', 'interrupt_after', 'out_of_steps']ÚstatuszRunControl | NoneÚcontrolzdict[str, PregelExecutableTask]ÚtaskszNone | dict[str, Any] | AnyÚoutputúset[str] | NoneÚupdated_channelszdeque[GraphLifecycleEvent]Ú_graph_lifecycle_eventsÚ_has_graph_lifecycle_callbacksrŠ   )r¬   r­   rª   Úmigrate_checkpointr°   r²   Úhas_graph_lifecycle_callbacksúBaseCache | NoneÚtrigger_to_nodesúMapping[str, Sequence[str]]rÔ   rÕ   r}   r€   c          
     óž  — || _         || _        || _        d| _        d| _        || _        || _        || _        || _        || _	        |	| _
        |
| _        || _        || _        || _        || _        t           | j                             t$          i ¦  «        v | _        t(          |t$                   v | _        || _        || _        || _        || _        || _        || _        t9          ¦   «         | _        | j         �Dt<          |t$                   v r0t?          | j         |t$                   t<                   ¦  «        | _         |t$                                        t@          ¦  «        }tC          |tD          ¦  «        rn| #                    ¦   «         x}rXtI          | j        tJ          tM          j'        |t$                   tJ                   tQ          |¦  «        f¦  «        i¦  «        | _        | j        sM|t$                                        tJ          ¦  «        r(tI          | j        tJ          dt(          d i¦  «        | _        tR          | j        t$                   v r¥| j        t$                                        tJ          ¦  «        | j        t$                   tR                   v r^tI          | j        t(          | j        t$                   tR                   | j        t$                   tJ                            i¦  «        | _*        n| j        | _*        | j*        t$                                        tV          ¦  «        x}rCtC          |tP          ¦  «        s.tI          | j*        tV          tQ          |¦  «        i¦  «        | _*        | j        t$                                        tJ          ¦  «        rUtY          t[          tP          | j        t$                   tJ                   ¦  «         .                    tL          ¦  «        ¦  «        nd| _/        d | _0        | j        t$                                        tb          ¦  «        }tC          |td          ¦  «        r|j3        nd | _3        d S )Nr   Ú rŠ   )4r…   r’   r”   r—   r˜   rš   r�   r›   rŸ   r¡   r£   r¤   r¥   r¬   r­   rª   r/   Úgetr%   r¨   r&   r§   r¸   r×   r°   r²   r®   rÓ   r   rÒ   r.   r�   r-   Ú
isinstancer<   Úsubgraph_counterr$   r(   r6   ÚjoinrÄ   r'   rÇ   r0   Útupler   ÚsplitrÆ   rË   r,   rp   rÍ   )Úselfrš   r…   r’   r”   r›   r�   rŸ   r¡   r£   r¤   r¥   r×   r®   r¬   r­   rª   rÔ   r°   r²   rÕ   Ú
scratchpadÚcntÚ	thread_idÚruntimes                            r†   Ú__init__zPregelLoop.__init__  s‡  € ð0 ˆŒØˆŒØˆŒ
ØˆŒ	ØˆŒ	ØˆŒ
Ø(ˆÔØˆŒ
ØˆŒ
ØˆŒ
Ø$ˆŒØ&ˆÔØ&ˆÔØ.ˆÔØ 0ˆÔØˆŒÝ+¨t¬{¯ª½tÀRÑ/HÔ/HÐHˆŒÝ4¸½t¼ÐDˆÔØ#5ˆÔ Ø 0ˆÔØ(ˆÔØ(ˆÔØ$ˆŒØ.KˆÔ+Ý',¡w¤wˆÔ$ØŒ;Ð"Õ'8¸FÅ4¼LÐ'HÐ'HÝ& t¤{°F½4´LÕARÔ4SÑTÔTˆDŒKØ.4µT¬l×.>Ò.>Õ?TÑ.UÔ.Uˆ
Ý�jÕ"2Ñ3Ô3ð 	ð !×1Ò1Ñ3Ô3Ð3ˆsð Ý0Ø”Kå0µ&´+à &¥t¤Õ-EÔ FÝ # C¡¤ðñ3ô 3ðñ
ô 
�”ð Œ~ð 	 &­¤,×"2Ò"2Õ3KÑ"LÔ"Lð 	Ý,Ø”Ý)¨2Õ/GÈÐNñô ˆDŒKõ
 &¨¬µTÔ):Ð:Ð:Ø”�DÔ!×%Ò%Õ&>Ñ?Ô?ØŒ{�4Ô Õ!:Ô;ð<ð <õ &8Ø”å,¨d¬k½$Ô.?Ý1ô/à”k¥$Ô'Õ(@ÔAô/Cðñ&ô &ˆDÔ"Ð"ð &*¤[ˆDÔ"ØÔ.­tÔ4×8Ò8Õ9MÑNÔNÐNˆ9ð 	Ý˜i­Ñ-Ô-ð Ý);ØÔ*Ý)­3¨y©>¬>Ð:ñ*ô *�Ô&ð Œ{�4Ô ×$Ò$Õ%=Ñ>Ô>ð�E•$•s˜DœK­Ô-Õ.FÔGÑHÔH×NÒNÍvÑVÔVÑWÔWÐWàð 	Ôð
 '+ˆÔ#Ø”+�dÔ#×'Ò'Õ(:Ñ;Ô;ˆÝ*4°W½gÑ*FÔ*FÐP�w”�ÈDˆŒˆˆrˆ   ©Ú
interruptsÚkindúLiteral['resume', 'interrupt']rè   útuple[Interrupt, ...]c          	     óz  — | j         dk    rt          d¦  «        ‚| j         }|dk    r=| j                             t	          d || j        d         | j        ¬¦  «        ¦  «         d S |dk    r>| j                             t          d || j        d         | j        |¬¦  «        ¦  «         d S d|› �}t          |¦  «        ‚)	NÚdrainingz,Draining status cannot emit lifecycle eventsÚresumeÚid)Úrun_idrÌ   Úcheckpoint_idrÆ   Ú	interrupt)rð   rÌ   rñ   rÆ   rè   z$Unknown graph lifecycle event type: )	rÌ   ÚRuntimeErrorrÒ   ÚappendrA   rÃ   rÆ   r?   ÚAssertionError)rá   ré   rè   rÌ   Úmsgs        r†   Ú_push_graph_lifecycle_eventz&PregelLoop._push_graph_lifecycle_eventx  sú   € ð Œ;˜*Ò$Ð$ÝÐMÑNÔNÐNØ”ˆØ�8ÒÐØÔ(×/Ò/Ý ØØ!Ø"&¤/°$Ô"7Ø"&Ô"4ð	ñ ô ñô ð ð ð ð �[Ò Ð ØÔ(×/Ò/Ý#ØØ!Ø"&¤/°$Ô"7Ø"&Ô"4Ø)ðñ ô ñô ð ð ð ð @¸Ð?Ð?ˆCÝ  Ñ%Ô%Ð%rˆ   úGraphLifecycleEvent | Nonec                óF   — | j         sd S | j                              ¦   «         S ©N)rÒ   Úpopleft©rá   s    r†   Ú_pop_lifecycle_eventzPregelLoop._pop_lifecycle_eventš  s'   € ØÔ+ð 	Ø�4ØÔ+×3Ò3Ñ5Ô5Ð5rˆ   Útask_idÚwritesÚWritesTc           	     óÊ  ‡ ‡— |sdS t          d„ |D ¦   «         ¦  «        r+t          d„ |D ¦   «                              ¦   «         ¦  «        }‰t          k    r<ˆfd„‰ j        D ¦   «         ‰ _        ˆfd„‰ j        D ¦   «         t          |¦  «        z   }nˆfd„‰ j        D ¦   «         ‰ _        |}t          d„ ‰ j                             ¦   «         D ¦   «         ¦  «        rˆ fd„|D ¦   «         }‰ j                             ˆfd	„|D ¦   «         ¦  «         |D ]A\  }}t          ‰ j	         
                    |¦  «        t          ¦  «        rt          |¦  «         ŒB‰ j        d
k    �r[‰ j        ��St          ‰ j        t"          ‰ j        t&                    
                    t"          d¦  «        t(          ‰ j        d         i¦  «        }‰ j        rbt/          ‰ d¦  «        r‰ j         
                    ‰¦  «        }nd}‰                      ‰ j        ||‰|rt5          |j        ¦  «        nd¦  «        }n‰                      ‰ j        ||‰¦  «        }‰ j        �5t          ˆ fd„|D ¦   «         ¦  «        r‰ j                             |¦  «         ‰ j        �3t          d„ |D ¦   «         ¦  «        r‰ j                             |¦  «         t/          ‰ d¦  «        r‰                      ‰|¦  «         dS dS )ú3Put writes for a task, to be read by the next tick.Nc              3  ó4   K  — | ]}|d          t           v V — ŒdS ©r   N©r   ©r‹   Úws     r†   ú	<genexpr>z(PregelLoop.put_writes.<locals>.<genexpr>¤  s+   è è € Ð6Ð6¨!ˆq�Œt•~Ð%Ð6Ð6Ð6Ð6Ð6Ð6rˆ   c                ó    — i | ]}|d          |“ŒS ©r   rŠ   r  s     r†   ú
<dictcomp>z)PregelLoop.put_writes.<locals>.<dictcomp>¥  s   € Ð3Ð3Ð3 q˜1˜Qœ4 Ð3Ð3Ð3rˆ   c                óJ   •— g | ]}|d          ‰k    s|d         t           v¯|‘Œ S )r   r‚   r  ©r‹   r  rþ   s     €r†   ú
<listcomp>z)PregelLoop.put_writes.<locals>.<listcomp>¨  s>   ø€ ð .ð .ð .àØ�Q”4˜7’?�? a¨¤dµ.Ð&@Ð&@ð à&@Ð&@Ð&@rˆ   c                ó<   •— g | ]}|d          ‰k    ¯|dd…         ‘ŒS ©r   r‚   NrŠ   r  s     €r†   r  z)PregelLoop.put_writes.<locals>.<listcomp>­  s1   ø€ ð 'ð 'ð 'ØÀÀ1ÄÈÂÀ��!�"�"”ÀÀÀrˆ   c                ó,   •— g | ]}|d          ‰k    ¯|‘ŒS r
  rŠ   r  s     €r†   r  z)PregelLoop.put_writes.<locals>.<listcomp>²  s)   ø€ ð .ð .ð .Ø¸Q¸q¼TÀWº_¸_�¸_¸_¸_rˆ   c              3  ó@   K  — | ]}t          |t          ¦  «        V — Œd S rú   ©rÜ   rE   ©r‹   Úchannels     r†   r  z(PregelLoop.put_writes.<locals>.<genexpr>¸  s=   è è € ð 
ð 
Ø4;�J�w¥Ñ/Ô/ð
ð 
ð 
ð 
ð 
ð 
rˆ   c                óæ   •— g | ]m\  }}t          ‰j                             |¦  «        t          ¦  «        °2|t          k    r,t          |t
          ¦  «        r|t          |‰j        ¦  «        fn||f‘ŒnS rŠ   )rÜ   r¡   rÛ   rE   r:   rx   rT   rº   ©r‹   ÚcÚvrá   s      €r†   r  z)PregelLoop.put_writes.<locals>.<listcomp>¼  s„   ø€ ð 
ð 
ð 
ñ �A�qå! $¤*§.¢.°Ñ"3Ô"3µ^ÑDÔDð
ð �E’z�z¥j°µDÑ&9Ô&9�zð Õ9¸!¸T¼]ÑKÔKÐLÐLà˜Q˜ð
ð 
ð 
rˆ   c              3  ó(   •K  — | ]\  }}‰||fV — Œd S rú   rŠ   )r‹   r  r  rþ   s      €r†   r  z(PregelLoop.put_writes.<locals>.<genexpr>É  s-   øè è € Ð-QÐ-QÁ$À!ÀQ¨w¸¸1¨oÐ-QÐ-QÐ-QÐ-QÐ-QÐ-Qrˆ   ÚexitrÚ   rï   rÎ   c              3  óx   •K  — | ]4\  }}t          ‰j                             |¦  «        t          ¦  «        V — Œ5d S rú   ©rÜ   r¡   rÛ   rD   )r‹   r  Ú_rá   s      €r†   r  z(PregelLoop.put_writes.<locals>.<genexpr>ï  sP   øè è € ð :ð :Ù@DÀÀ1•
˜4œ:Ÿ>š>¨!Ñ,Ô,­lÑ;Ô;ð:ð :ð :ð :ð :ð :rˆ   c              3  ó2   K  — | ]\  }}|t           k    V — Œd S rú   )r2   )r‹   r  r  s      r†   r  z(PregelLoop.put_writes.<locals>.<genexpr>ö  sE   è è € ð Bð BÙ+/¨1¨a�Õ&Ò&ðBð Bð Bð Bð Bð Brˆ   ) ÚallÚlistÚvaluesr7   rÉ   Úanyrº   ÚextendrÜ   r¡   rÛ   rD   rf   r®   r´   r$   rÇ   r(   r’   r%   r&   rÃ   rµ   ÚhasattrrÎ   r¹   rV   Úpathr»   rô   r¼   Úoutput_writes)	rá   rþ   rÿ   Úwrites_to_saver  r  r’   ÚtaskÚfuts	   ``       r†   Ú
put_writeszPregelLoop.put_writesŸ  s¶  øø€ àð 	ØˆFåÐ6Ð6¨vÐ6Ñ6Ô6Ñ6Ô6ð 	>ÝÐ3Ð3¨FÐ3Ñ3Ô3×:Ò:Ñ<Ô<Ñ=Ô=ˆFØ•lÒ"Ð"ð.ð .ð .ð .àÔ7ð.ñ .ô .ˆDÔ*ð
'ð 'ð 'ð 'Ø#Ô=ð'ñ 'ô 'å�V‘”ñ'ˆNˆNð
.ð .ð .ð .ØÔ9ð.ñ .ô .ˆDÔ*ð $ˆNõ ð 
ð 
Ø?C¼}×?SÒ?SÑ?UÔ?Uð
ñ 
ô 
ñ 
ô 
ð 	ð
ð 
ð 
ð 
ð +ð
ñ 
ô 
ˆNð 	Ô&×-Ò-Ð-QÐ-QÐ-QÐ-QÈ&Ð-QÑ-QÔ-QÑQÔQÐQð #ð 	&ð 	&‰DˆAˆqÝ˜$œ*Ÿ.š.¨Ñ+Ô+­\Ñ:Ô:ð &Ý" 1Ñ%Ô%Ð%øØŒ?˜fÒ$Ñ$¨Ô)EÑ)QÝ'ØÔ&å,¨d¬k½$Ô.?×.CÒ.CÝ0°"ñ/ô /õ -¨d¬o¸dÔ.Cð	ñô ˆFð Ô=ð Ý˜4 Ñ)Ô)ð  Øœ:Ÿ>š>¨'Ñ2Ô2�D�Dà�DØ—k’kØÔ0ØØ"ØØ04Ð<•M $¤)Ñ,Ô,Ð,¸"ñô ��ð —k’kØÔ0ØØ"Øñ	ô �ð Ô%Ð1µcð :ð :ð :ð :ØHVð:ñ :ô :ñ 7ô 7Ð1ð Ô&×-Ò-¨cÑ2Ô2Ð2ð Ô-Ð9½cð Bð BØ39ðBñ Bô Bñ ?ô ?Ð9ð Ô.×5Ò5°cÑ:Ô:Ð:å�4˜Ñ!Ô!ð 	0Ø×Ò˜w¨Ñ/Ô/Ð/Ð/Ð/ð	0ð 	0rˆ   c           
     ó�  — | j         €d S | j        sd S t          | j        t          | j        t                                        t          d¦  «        t          | j	        d         i¦  «        }t          t          ¦  «        }| j        D ]#\  }}}||                              ||f¦  «         Œ$|                     ¦   «         D ]ˆ\  }}| j        r_t          | d¦  «        rO| j                             |¦  «        }|                      | j         ||||rt%          |j        ¦  «        nd¦  «         Œk|                      | j         |||¦  «         Œ‰d S )NrÚ   rï   rÎ   )r´   rÉ   r$   rÇ   r(   r’   r%   rÛ   r&   rÃ   r   r!  rô   Úitemsrµ   r%  rÎ   r¹   rV   r&  )rá   r’   Úby_taskrþ   r  r   rÿ   r)  s           r†   Ú_put_pending_writeszPregelLoop._put_pending_writesþ  s|  € ØÔ'Ð/ØˆFØÔ-ð 	ØˆFå#ØÔ"å(¨$¬+µdÔ*;×*?Ò*?Ý,¨bñ+ô +õ )¨$¬/¸$Ô*?ð	ñ
ô 
ˆõ �dÑ#Ô#ˆØ'+Ô'Eð 	6ð 	6Ñ#ˆG�W˜eØ�GÔ×#Ò# W¨eÐ$4Ñ5Ô5Ð5Ð5à&Ÿ}š}™œð 	ð 	‰OˆG�VØÔ=ð Å'Ø�gñCô Cð ð ”z—~’~ gÑ.Ô.�Ø—’ØÔ0ØØØØ04Ð<•M $¤)Ñ,Ô,Ð,¸"ñô ð ð ð —’ØÔ0ØØØñ	ô ð ð ð	ð 	rˆ   r)  rv   Ú	write_idxÚcallúCall | NoneúPregelExecutableTask | Nonec           
     óˆ  — t          j        | j        d                              dd¦  «        ¦  «        }t	          | j        ¦  «        }t          t          dz  t          t          |j	        ||j
        |fdfi d| j        “d|“d|“d| j        “d	| j        “d
| j        “d| j        “d|j        “d| j        “d| j        “dd“d| j        “d| j        “d| j        “d| j        “d| j        “Ž¦  «        x}rQ|                      dt0          |g¦  «         || j        |j
        <   | j        s|                      |j
        |i¦  «         |S dS )zEAccept a PUSH from a task, potentially returning a new task to start.rï   ú-rÚ   NrÃ   Úcheckpoint_id_bytesrO   Úpending_writesÚ	processesrº   rÂ   r’   r—   r˜   Úfor_executionTr”   r�   rª   r°   r²   rÎ   )ÚbinasciiÚ	unhexlifyrÃ   ÚreplacerO   r   rv   rS   r8   r&  rï   rÉ   rŸ   rº   rÂ   r’   r—   r˜   r”   r�   rª   r°   r²   Ú_emitrl   rÎ   r§   Ú"_reapply_writes_to_succeeded_nodes)rá   r)  r0  r1  r6  Únull_versionÚpusheds          r†   Úaccept_pushzPregelLoop.accept_push&  sÅ  € õ 'Ô0°´ÀÔ1F×1NÒ1NÈsÐTVÑ1WÔ1WÑXÔXÐÝ.¨t¬Ñ?Ô?ˆÝÝ  4Ñ'ÝÝ�t”y )¨T¬W°dÐ;Øðð ð ð  œ?˜?ðð %8Ð$7ð	ð
 )5¨ðð  $Ô=Ð=ðð œ*˜*ðð œ˜ðð œ˜ðð ”{�{ðð ”Y�Yðð ”Y�Yðð #˜dðð ”j�jðð "Ô.Ð.ðð  œ˜ð!ð" "Ô.Ð.ð#ð$ "Ô.Ð.ð%ñ
ô 
ð 
ˆ6ð 	ð0 �JŠJ�w¥°&°Ñ:Ô:Ð:à$*ˆDŒJ�v”yÑ!àÔ$ð MØ×7Ò7¸¼ÀFÐ8KÑLÔLÐLàˆMð?	ð 	rˆ   Úfailed_taskÚerrorÚBaseExceptionc                ó   — t           ‚rú   ©ÚNotImplementedError©rá   rB  rC  s      r†   Úschedule_error_handlerz!PregelLoop.schedule_error_handlerM  s
   € õ "Ð!rˆ   c              ƒ  ó   K  — t           ‚rú   rF  rH  s      r†   Úaschedule_error_handlerz"PregelLoop.aschedule_error_handlerR  s   è è € õ "Ð!rˆ   c                óœ  — | j         | j        k    r	d| _        dS t          | j        | j        | j        | j        | j        | j	        | j         | j        d| j
        | j        | j        | j        | j        | j        | j        ¬¦  «        | _        | j        �Ž|                      dt(          i | j        ¥t,          i | j        t,                   ¥t.          | j        d         i¥i¥| j        | j        | j        | j                             ¦   «         | j        | j        | j        ¦
  «
         | j        s	d| _        dS | j        �| j        j        r	d	| _        dS | j        s5| j        r.|                       | j        ¦  «         |  !                    ¦   «          | j"        rGtG          | j        | j"        | j                             ¦   «         ¦  «        rd
| _        tI          ¦   «         ‚|                      dtJ          | j                             ¦   «         ¦  «         | j                             ¦   «         D ]+}|j&        r"|  '                    |j(        |j&        d¬¦  «         Œ,dS )zyExecute a single iteration of the Pregel loop.

        Returns:
            True if more iterations are needed.
        Úout_of_stepsFT)r9  rª   r”   r�   r×   rÑ   r°   r²   NÚcheckpointsrï   Údonerí   r­   rÎ   ©Úcached))r—   r˜   rÌ   rQ   rÃ   rÉ   rŸ   rº   rÂ   r’   rª   r”   r�   r×   rÑ   r°   r²   rÎ   r¶   r=  rj   rÇ   r%   r&   r¥   rÈ   r"  rË   r¤   rÍ   Údrain_requestedr§   r>  Ú$_resume_error_handlers_if_applicabler­   rU   rH   rl   rÿ   r'  rï   )rá   r)  s     r†   ÚtickzPregelLoop.tickW  sj  € ð Œ9�t”yÒ Ð Ø(ˆDŒKØ�5õ (ØŒOØÔ*ØŒJØŒMØŒLØŒKØŒIØŒIØØ”LØ”*ØÔ*Ø!Ô2Ø!Ô2ØÔ*ØÔ*ð!
ñ 
ô 
ˆŒ
ð( Ô0Ð<Ø�JŠJØÝ$ðØÔ,ðåð ØÔ0µÔ6ðå0°$´/À$Ô2Gðð ðð ð ”ØÔ ØÔ(Ø”
×!Ò!Ñ#Ô#ØÔ.ØÔ+ØÔ ñ!ô ð ð( Œzð 	Ø ˆDŒKØ�5àŒ<Ð#¨¬Ô(DÐ#Ø$ˆDŒKØ�5ð Ô ð 	8 TÔ%Cð 	8Ø×3Ò3°D´JÑ?Ô?Ð?Ø×5Ò5Ñ7Ô7Ð7ð Ô ð 	#Õ%5ØŒO˜TÔ2°D´J×4EÒ4EÑ4GÔ4Gñ&
ô &
ð 	#ð -ˆDŒKÝ Ñ"Ô"Ð"ð 	�
Š
�7�O¨T¬Z×->Ò->Ñ-@Ô-@ÑAÔAÐAð ”J×%Ò%Ñ'Ô'ð 	Fð 	FˆDØŒ{ð FØ×"Ò" 4¤7¨D¬KÀÐ"ÑEÔEÐEøàˆtrˆ   c                ó  ‡ — d„ ‰ j                              ¦   «         D ¦   «         }‰ j                             ˆ fd„|D ¦   «         ¦  «         t	          ‰ j        ‰ j        ‰ j                              ¦   «         ‰ j        ‰ j        ¦  «        ‰ _	        ‰ j	         
                    t          ‰ j        t          ¦  «        r‰ j        fn‰ j        ¦  «        s(‰                      dt          ‰ j        |‰ j        ¦  «         ‰ j        �^‰ j        D ]V\  }}}t          ‰ j                             |¦  «        t(          ¦  «        r#‰ j                             ‰ j        |||f¦  «         ŒW‰ j                             ¦   «          d‰ _        ‰                      ddi¦  «         ‰ j        rGt7          ‰ j        ‰ j        ‰ j                              ¦   «         ¦  «        rd‰ _        t;          ¦   «         ‚‰ j        t>                                         tB          d ¦  «         d S )Nc                ó&   — g | ]}|j         D ]}|‘ŒŒS rŠ   ©rÿ   ©r‹   Útr  s      r†   r  z)PregelLoop.after_tick.<locals>.<listcomp>­  s'   € ÐCÐCÐC˜¸!¼(ÐCÐC°Q�!ÐCÐCÐCÐCrˆ   c              3  ó¦   •K  — | ]K\  }}t          ‰j                             |¦  «        t          ¦  «        ¯2t	          |¦  «        d          ¯G|V — ŒLdS r  ©rÜ   r¡   rÛ   rD   rC   )r‹   Úchr  rá   s      €r†   r  z(PregelLoop.after_tick.<locals>.<genexpr>®  ss   øè è € ð 3
ð 3
á��AÝ˜$œ*Ÿ.š.¨Ñ,Ô,­lÑ;Ô;ð3
õ AOÈqÑ@QÔ@QÐRSÔ@Tð3
Øð3
ð 3
ð 3
ð 3
ð 3
ð 3
rˆ   r"  FÚsourceÚloopr¬   )"rÎ   r"  r¿   ÚupdaterN   rÃ   rº   r³   r×   rÑ   Ú
isdisjointrÜ   r¤   rÄ   r=  rd   r½   rÉ   r¡   rÛ   rD   rô   r—   Úclearr§   Ú_put_checkpointr¬   rU   rÌ   rH   r’   r%   Úpopr+   )rá   rÿ   Útidr\  r  s   `    r†   Ú
after_tickzPregelLoop.after_tick«  s  ø€ àCÐC˜TœZ×.Ò.Ñ0Ô0ÐCÑCÔCˆØÔ+×2Ò2ð 3
ð 3
ð 3
ð 3
àð3
ñ 3
ô 3
ñ 	
ô 	
ð 	
õ !-ØŒOØŒMØŒJ×ÒÑÔØÔ.ØÔ!ñ!
ô !
ˆÔð Ô$×/Ò/å˜$Ô*­CÑ0Ô0ð"ˆTÔÐÐàÔ!ñ
ô 
ð 	ð
 �JŠJØÕ+¨TÔ-=¸vÀtÄ}ñô ð ð Ô"Ð.Ø"Ô<ð Lð L‘
��R˜Ý˜dœjŸnšn¨RÑ0Ô0µ,Ñ?Ô?ð LØÔ+×2Ò2°D´I¸sÀBÈÐ3JÑKÔKÐKøàÔ&×,Ò,Ñ.Ô.Ð.à!ˆÔà×Ò˜h¨Ð/Ñ0Ô0Ð0àÔð 	#Õ$4ØŒO˜TÔ1°4´:×3DÒ3DÑ3FÔ3Fñ%
ô %
ð 	#ð ,ˆDŒKÝ Ñ"Ô"Ð"àŒ•DÔ×ÒÕ1°4Ñ8Ô8Ð8Ð8Ð8rˆ   úSequence[PregelExecutableTask]c                ó   — t           ‚rú   rF  rü   s    r†   Úmatch_cached_writeszPregelLoop.match_cached_writesØ  s   € Ý!Ð!rˆ   c              ƒ  ó   K  — t           ‚rú   rF  rü   s    r†   Úamatch_cached_writeszPregelLoop.amatch_cached_writesÛ  s   è è € Ý!Ð!rˆ   ú"Mapping[str, PregelExecutableTask]c                óÂ   — | j         D ]V\  }}}|t          t          t          t          fv rŒ#|                     |¦  «        x}r|j                             ||f¦  «         ŒWdS )a*  Restore successful channel writes from checkpoint to in-memory tasks.

        Skips control signals (ERROR, ERROR_SOURCE_NODE, INTERRUPT, RESUME)
        so that failed/interrupted tasks remain with empty writes and will be
        re-executed (or routed to error handlers) by the runner.
        N)rÉ   r1   r2   r4   r9   rÛ   rÿ   rô   )rá   rÎ   rd  Úkr  r)  s         r†   r>  z-PregelLoop._reapply_writes_to_succeeded_nodesà  sp   € ð Ô7ð 	+ð 	+‰IˆC��AØ•UÕ-­y½&ÐAÐAÐAØØ—y’y ‘~”~Ð%ˆtð +Ø”×"Ò" A q 6Ñ*Ô*Ð*øð		+ð 	+rˆ   c                óL  ‡	— i }| j         D ]9\  Š	}}|t          k    r(t          ˆ	fd„| j         D ¦   «         d¦  «        }|�||‰	<   Œ:|                     ¦   «         D ]Ê\  }}| j                             |¦  «        }|€Œ"| j        |j                 j        }|sŒ<|j	         
                    t          |f¦  «         t          |f||| j        | j         | j        | j        | j        |j        | j        | j        | j        | j        | j        | j        | j        dœŽ}|�|| j        |j        <   ŒËdS )um  On resume, schedule error handlers for tasks that failed in a prior run.

        Called right after ``_reapply_writes_to_succeeded_nodes`` during ``tick()``.
        At that point, ``_reapply_writes_to_succeeded_nodes`` has already skipped
        ERROR / ERROR_SOURCE_NODE writes, so a previously-failed task still has
        empty ``writes``.  Without intervention the runner (which executes only
        tasks where ``not t.writes``) would re-run the original node.

        This method prevents that re-execution for nodes that have an error
        handler:

        1. Scan ``checkpoint_pending_writes`` for ERROR_SOURCE_NODE markers
           persisted by a prior ``commit()``.  Each marker means "this task
           already failed and was routed to an error handler".
        2. For each such task, write ``(ERROR, error)`` into ``task.writes``
           so the task is no longer empty â€” the runner will skip it.
        3. Prepare a fresh error-handler task and add it to ``self.tasks``.
           Because the handler task starts with empty ``writes``, the runner
           will pick it up and execute it.
        c              3  óF   •K  — | ]\  }}}|‰k    ¯|t           k    ¯|V — Œd S rú   )r1   )r‹   rY  r  r  rd  s       €r†   r  zBPregelLoop._resume_error_handlers_if_applicable.<locals>.<genexpr>	  sC   øè è € ð ð á#˜A˜q !Ø š8˜8¨­Uª
¨
ð à(2¨
¨
¨
ðð rˆ   N©Úhandler_node_nameÚfailed_errorrÃ   r7  r8  rº   rÂ   r’   r—   r˜   r”   r�   rª   r°   r²   )rÉ   r2   Únextr-  rÎ   rÛ   rŸ   ÚnameÚerror_handler_noderÿ   rô   r1   rR   rÃ   rº   rÂ   r’   r—   r˜   r”   r�   rª   r°   r²   rï   )
rá   ÚfailedÚchanÚvalrC  rþ   r)  Úhandler_nodeÚhandler_taskrd  s
            @r†   rS  z/PregelLoop._resume_error_handlers_if_applicableï  sq  ø€ ð, ,.ˆØ"Ô<ð 	(ð 	(‰NˆC��sØÕ(Ò(Ð(Ýðð ð ð à'+Ô'Eðñ ô ð
 ñô �ð Ð$Ø"'�F˜3‘Køà$Ÿlšl™nœnð 	;ð 	;‰NˆG�UØ”:—>’> 'Ñ*Ô*ˆDØˆ|ØØœ: d¤iÔ0ÔCˆLØð ØàŒK×Ò¥ u˜~Ñ.Ô.Ð.å:Øðà".Ø"Øœ?Ø#Ô=Øœ*ØœØœØ”{Ø”YØ”YØ”jØ!Ô.ØœØ!Ô.Ø!Ô.ð!ð ð ˆLð$ Ð'Ø.:�”
˜<œ?Ñ+øð;	;ð 	;rˆ   c                ó  ‡‡— i Št          ¦   «         }| j        D ]B\  }}}|t          k    r|d         j        ‰|<   Œ"|t          k    r|                     |¦  «         ŒCˆfd„|D ¦   «         Šˆfd„‰                     ¦   «         D ¦   «         }|S )zUReturn the set of interrupt ids that are pending without corresponding resume values.r   c                ó(   •— h | ]}|‰v ¯‰|         ’ŒS rŠ   rŠ   )r‹   rþ   Úpending_interruptss     €r†   rŽ   z1PregelLoop._pending_interrupts.<locals>.<setcomp>A  s4   ø€ ð !
ð !
ð !
àØÐ,Ð,Ð,ð ˜wÔ'à,Ð,Ð,rˆ   c                ó   •— h | ]}|‰v¯|’Œ	S rŠ   rŠ   )r‹   Úinterrupt_idÚresumed_interrupt_idss     €r†   rŽ   z1PregelLoop._pending_interrupts.<locals>.<setcomp>H  s/   ø€ ð (
ð (
ð (
àØÐ#8Ð8Ð8ð à8Ð8Ð8rˆ   )ÚsetrÉ   r4   rï   r9   Úaddr"  )rá   Úpending_resumesrþ   Ú
write_typer   Úhanging_interruptsr}  r€  s         @@r†   Ú_pending_interruptszPregelLoop._pending_interrupts2  sÕ   øø€ ð .0Ðõ %(¡E¤Eˆà*.Ô*Hð 	-ð 	-Ñ&ˆG�Z Ø�YÒ&Ð&à.3°A¬h¬kÐ" 7Ñ+Ð+Ø�vÒ%Ð%Ø×#Ò# GÑ,Ô,Ð,øð!
ð !
ð !
ð !
à*ð!
ñ !
ô !
Ðð(
ð (
ð (
ð (
à 2× 9Ò 9Ñ ;Ô ;ð(
ñ (
ô (
Ðð "Ð!rˆ   c               ó@  ‡ — ‰ j                              t          i ¦  «        }t          ‰ j        t
          ¦  «        }t          ‰ j        d         ¦  «        oˆt          |                     t          ‰ j        d u pY|pW‰ j	         oO‰ j                              di ¦  «                             d¦  «        ‰ j
                             dt          ¦  «        k    ¦  «        ¦  «        }‰ j        o{‰ j	        o5|                     t          d¦  «        |                     t          i ¦  «        v p>|r!t          t
          ‰ j        ¦  «        j        d up|                     t          d¦  «         }|rd„ ‰ j        D ¦   «         ‰ _        |�rft          t
          ‰ j        ¦  «        j        x}�•‰ j        st'          d¦  «        ‚t          |t(          ¦  «        ot+          d„ |D ¦   «         ¦  «        x}r|‰ j         t                   t,          <   n4t/          ‰                      ¦   «         ¦  «        d	k    rt'          d
¦  «        ‚t3          t4          ¦  «        }	t7          t          t
          ‰ j        ¦  «        ¬¦  «        D ]0\  }
}}|t8          k    r|s|	|
                              ||f¦  «         Œ1|	s|st=          d¦  «        ‚|	                     ¦   «         D ]\  }
}‰                       |
|¦  «         Œd„ ‰ j        D ¦   «         x}rTtC          ‰ j        ‰ j"        tG          dtH          |g ¦  «        g‰ j%        ‰ j&        ¦  «        }|�| '                    |¦  «         |râ‰ j        d          (                    tR          i ¦  «         ‰ j"        D ]?}|‰ j        d         v r.‰ j        d         |         }|‰ j        d         tR                   |<   Œ@|rI‰ j
                             d¦  «        dvr-d„ ‰ j        D ¦   «         ‰ _        ‰  *                    ddi¦  «         ‰  +                    dtX          ‰ j-        d‰ j"        ¦  «         �nµt]          t_          |‰ j        ¦  «        ¦  «        x}�ruta          ‰ j        ‰ j        ‰ j1        ‰ j"        ‰ j2        ‰ j         ‰ j3        ‰ j4        dd d d |¬¦  «        }‰ j5         '                    ˆ fd„|D ¦   «         ¦  «         tC          ‰ j        ‰ j"        g | 6                    ¦   «         ¢tG          dtH          |g ¦  «        ‘‰ j%        ‰ j&        ¦  «        }‰ j7        �]|D ]Z\  }}t          ‰ j8                             |¦  «        tr          ¦  «        r(‰ j7                             ‰ j3        tt          ||f¦  «         Œ[‰ j;        dk    r+ˆ fd„|D ¦   «         }|r‰                       tt          |¦  «         |‰ _<        ‰  *                    ddi¦  «         nt          |vrt=          d|› �¦  «        ‚‰ j	        s–d }|rj‰ j        d         }‰ j
                             d¦  «        dv r2‰ j=        r+‰ j=        t                                        t|          |¦  «        }t          |¦  «        }t�          ‰ j         t          |t‚          |i¦  «        ‰ _         d‰ _B        |r‰  C                    d¦  «         |S )NÚchannel_versionsÚmetadatarð   rÚ   Fc                ó4   — g | ]}|d          t           k    ¯|‘ŒS ©r‚   )r9   r  s     r†   r  z%PregelLoop._first.<locals>.<listcomp>‚  s(   € ð .ð .ð .Ø¸Q¸q¼TÅVº^¸^�¸^¸^¸^rˆ   z3Cannot use Command(resume=...) without checkpointerc              3  ó4   K  — | ]}t          |¦  «        V — Œd S rú   )ri   )r‹   rm  s     r†   r  z$PregelLoop._first.<locals>.<genexpr>�  s+   è è € ÐEÐE¸Õ1°!Ñ4Ô4ÐEÐEÐEÐEÐEÐErˆ   r‚   zØWhen there are multiple pending interrupts, you must specify the interrupt id when resuming. Docs: https://docs.langchain.com/oss/python/langgraph/add-human-in-the-loop#resume-multiple-interrupts-with-one-invocation.)ÚcmdzReceived empty Command inputc                óD   — g | ]}|d          t           k    ¯|dd…         ‘ŒS r  )r7   r  s     r†   r  z%PregelLoop._first.<locals>.<listcomp>¥  s5   € ð 
ð 
ð 
Ø¸Q¸q¼TÅ\Ò=QÐ=QˆAˆaˆbˆbŒEÐ=QÐ=QÐ=Qrˆ   rŠ   Úversions_seenr]  )r_  Úforkc                ó4   — g | ]}|d          t           k    ¯|‘ŒS r‹  )r4   r  s     r†   r  z%PregelLoop._first.<locals>.<listcomp>È  s-   € ð 2ð 2ð 2ØÀÀ1ÄÍÒARÐAR�AÐARÐARÐARrˆ   r�  r"  T)r9  r”   r�   rª   rÑ   c              3  ó¦   •K  — | ]K\  }}t          ‰j                             |¦  «        t          ¦  «        ¯2t	          |¦  «        d          ¯G|V — ŒLdS r  r[  r  s      €r†   r  z$PregelLoop._first.<locals>.<genexpr>â  st   øè è € ð 7ð 7á�A�qÝ˜dœjŸnšn¨QÑ/Ô/µÑ>Ô>ð7õ DRÐRSÑCTÔCTÐUVÔCWð7Øð7ð 7ð 7ð 7ð 7ð 7rˆ   r  c                óx   •— g | ]6\  }}t          ‰j                             |¦  «        t          ¦  «        ¯2||f‘Œ7S rŠ   r  r  s      €r†   r  z%PregelLoop._first.<locals>.<listcomp>   sO   ø€ ð ð ð á˜˜1Ý! $¤*§.¢.°Ñ"3Ô"3µ\ÑBÔBðØ˜�Fðð ð rˆ   rš   zReceived no input for rï   Úpendingrî   )Dr’   rÛ   r%   rÜ   rš   rs   r¦   rÃ   r+   r¨   rÈ   r>   r§   r(   r'   r   rî   rÉ   r�   ró   Údictr   r*   Úlenr†  r   r!  ra   r9   rô   rG   r-  r+  rN   rº   rM   r3   r³   r×   r_  Ú
setdefaultr4   rb  r=  rd   r¤   r   rb   rQ   rŸ   rÂ   r—   r˜   r¿   r"  r½   r¡   rD   r7   r®   rÑ   rË   r&   r;   r$   r)   rÌ   r÷   )rá   r£   rÑ   ÚconfigurableÚinput_is_commandÚis_resumingÚis_time_travelingrî   Úresume_is_maprÿ   rd  r  r  ÚwsÚnull_writesÚnull_updated_channelsrm  ÚversionÚinput_writesÚdiscard_tasksÚdelta_inputÚreplay_stateÚreplay_checkpoint_ids   `                      r†   Ú_firstzPregelLoop._firstP  s�  ø€ ð ”{—’¥t¨RÑ0Ô0ˆÝ% d¤jµ'Ñ:Ô:ÐÝ˜4œ?Ð+=Ô>Ñ?Ô?ð 
ÅDØ×ÒÝ#Ø”
˜dÐ"ð Ø#ðð œÐ&ð GØœŸš¨
°BÑ7Ô7×;Ò;¸HÑEÔEØÔ/×3Ò3°H½gÑFÔFòGñ	ô 	ñE
ô E
ˆð" !Ô-ð 
ð ”ð CØ ×$Ò$Õ%=¸rÑBÔBØ×#Ò#Õ$=¸rÑBÔBðCðð "ÐR¥d­7°D´JÑ&?Ô&?Ô&FÈdÐ&Rð @ð  ×#Ò#Õ$7¸Ñ?Ô?ðð 	ð& ð 	ð.ð .ØÔ9ð.ñ .ô .ˆDÔ*ð
 ñ 	)Ý�w¨¬
Ñ3Ô3Ô:Ð:�ÐGØÔ(ð Ý&ØMñô ð õ
 ˜v¥tÑ,Ô,ð FÝÐEÐE¸fÐEÑEÔEÑEÔEð�=ð 
ð @F�D”K¥Ô%Õ&;Ñ<Ð<å˜4×3Ò3Ñ5Ô5Ñ6Ô6¸Ò:Ð:Ý*ðZñô ð õ
 ?JÍ$Ñ>OÔ>OˆFå(­Tµ'¸4¼:Ñ-FÔ-FÐGÑGÔGð /ð /‘	��Q˜Ø�Vš˜¨˜Ø˜3”K×&Ò&¨¨1 vÑ.Ô.Ð.øØð F -ð FÝ%Ð&DÑEÔEÐEà!Ÿ<š<™>œ>ð )ð )‘��RØ—’  RÑ(Ô(Ð(Ð(ð
ð 
ØÔ9ð
ñ 
ô 
ð 
ˆ;ð 	?õ %1Ø”Ø”Ý! "¥e¨[¸"Ñ=Ô=Ð>ØÔ2ØÔ%ñ%ô %Ð!ð  Ð+Ø ×'Ò'Ð(=Ñ>Ô>Ð>àð Y	IØŒO˜OÔ,×7Ò7½	À2ÑFÔFÐFØ”]ð Mð M�Ø˜œÐ(:Ô;Ð;Ð;Ø"œoÐ.@ÔAÀ!ÔD�GØEL�D”O OÔ4µYÔ?ÀÑBøð !ð 9 TÔ%=×%AÒ%AÀ(Ñ%KÔ%Kð Tð &ð &ð2ð 2Ø#Ô=ð2ñ 2ô 2�Ô.ð ×$Ò$ h°Ð%7Ñ8Ô8Ð8à�JŠJØÕ+¨TÔ-=¸tÀTÄ]ñô ð ñ õ #¥9¨Z¸¼Ñ#DÔ#DÑEÔEÐEˆ\ñ :	Iå.Ø”ØÔ.Ø”
Ø”Ø”Ø”Ø”	Ø”	Ø"ØØ!ØØ!1ðñ ô ˆMð Ô/×6Ò6ð 7ð 7ð 7ð 7à(ð7ñ 7ô 7ñ ô ð õ  ,Ø”Ø”ðØ"×)Ò)Ñ+Ô+ðå$ R­°¸bÑAÔAðð Ô2ØÔ%ñ	 ô 	 Ðð" Ô&Ð2Ø(ð Xð X‘D�A�qÝ! $¤*§.¢.°Ñ"3Ô"3µ\ÑBÔBð XØÔ/×6Ò6¸¼	Å<ÐQRÐTUÐ7VÑWÔWÐWøð Œ &Ò(Ð(ðð ð ð à ,ðñ ô �ð
 ð ?Ø—O’O¥L°+Ñ>Ô>Ð>à$4ˆDÔ!Ø× Ò  (¨GÐ!4Ñ5Ô5Ð5Ð5Ý ¨Ð4Ð4Ý!Ð"G¸:Ð"GÐ"GÑHÔHÐHàŒ~ð %	ð  04ˆLØ ð AØ'+¤°tÔ'<Ð$àÔ,×0Ò0°Ñ:Ô:ððð ð
 Ô3ðð ,0Ô+FÅtÔ+L×+PÒ+PÝ0Ð2Fñ,ô ,Ð(õ  +Ð+?Ñ@Ô@�Ý,Ø”å'¨Ý+¨\ðñô ˆDŒKð  ˆŒØð 	7Ø×,Ò,¨XÑ6Ô6Ð6ØÐrˆ   r‰  c           	     óN  ‡ — |‰ j         u }|r‰ j        d         ‰ j        k    rd S |sãt          ‰ j                              d¦  «        pi ¦  «        }i }‰ j        pt          ¦   «         }‰ j                             ¦   «         D ]I\  }}t          |t          ¦  «        sŒ|                     |d¦  «        \  }}	|	dz  }	||v r|dz  }||	f||<   ŒJ‰ j        |d<   ‰ j        t                                        t          i ¦  «        |d<   |‰ _         n)t          ‰ j                              d¦  «        pi ¦  «        }‰ j        d uo|p
‰ j        dk    }
|
rt#          ‰ j        |¦  «        ‰ j        z  nt          ¦   «         }t'          ‰ j        |
r‰ j        nd ‰ j        |r‰ j        d         nd ‰ j        |
r‰ j        nd |¬¦  «        ‰ _        |D ]}d||<   Œ|
r‰ j                             |¦  «         d	„ |                     ¦   «         D ¦   «         }|r|‰ j         d<   nd‰ j         v r‰ j         d= t,          ‰ j        d
         v rit/          d„ ‰ j                             ¦   «         D ¦   «         ¦  «        r9ˆ fd„‰ j        d
         t,                   D ¦   «         }|‰ j        d
         t,          <   |
�rn‰ j        ��ft2          ‰ j        t                   v r$‰ j        t                   t2                   r‰ j        nd ‰ _        i ‰ j        ¥t          i ‰ j        t                   ¥t8          ‰ j        t                                        t8          d¦  «        i¥i¥‰ _        ‰ j        d                              ¦   «         }t=          ‰ j        |¦  «        }|‰ _        ‰                       ‰ j        tC          ‰ dd ¦  «        ‰ j        tE          ‰ j        ¦  «        ‰ j         |¦  «        ‰ _#        i ‰ j        ¥t          i ‰ j        t                   ¥t2          ‰ j        d         i¥i¥‰ _        |s‰ xj        dz  c_        d S d S )Nrï   Úcounters_since_delta_snapshot©r   r   r‚   r—   Úparentsr  )rï   rÑ   Úget_next_versionÚchannels_to_snapshotc                ó&   — i | ]\  }}|d k    ¯||“ŒS )r©  rŠ   )r‹   rm  r  s      r†   r  z.PregelLoop._put_checkpoint.<locals>.<dictcomp>†  s#   € ÐIÐIÐI™T˜Q ¸QÀ&º[¸[�A�q¸[¸[¸[rˆ   Úchannel_valuesc              3  ó@   K  — | ]}t          |t          ¦  «        V — Œd S rú   r  r  s     r†   r  z-PregelLoop._put_checkpoint.<locals>.<genexpr>Œ  s=   è è € ð >
ð >
Ø4;�J�w¥Ñ/Ô/ð>
ð >
ð >
ð >
ð >
ð >
rˆ   c                óh   •— g | ].}t          |t          ¦  «        rt          |‰j        ¦  «        n|‘Œ/S rŠ   )rÜ   rx   rT   rº   )r‹   r   rá   s     €r†   r  z.PregelLoop._put_checkpoint.<locals>.<listcomp>�  sO   ø€ ð ð ð ð õ ˜e¥TÑ*Ô*ðÕ1°%¸¼ÑGÔGÐGàðð ð rˆ   rÚ   rˆ  Ú_put_checkpoint_fut)$rÈ   rÃ   rÅ   r•  rÛ   rÑ   r�  rº   r-  rÜ   rD   r—   r’   r%   r'   r¶   r®   r[   r¿   rZ   r³   Údifference_updater:   r#  r"  r&   rÇ   rË   r(   Úcopyrh   rÊ   r¹   ÚgetattrrY   r±  )rá   r‰  ÚexitingÚprev_countersÚnew_countersÚupdatedÚch_namer\  ÚurŒ   Údo_checkpointr¬  rm  Únon_zeroÚsanitized_tasksrˆ  Únew_versionss   `                r†   rb  zPregelLoop._put_checkpoint9  sú  ø€ ð ˜dÔ6Ð6ˆØð 	�t” tÔ,°Ô0HÒHÐHàˆFð  ð 	Ý ØÔ(×,Ò,Ð-LÑMÔMÐSÐQSñô ˆMð 8:ˆLØÔ+Ð4­s©u¬uˆGØ#œ}×2Ò2Ñ4Ô4ð /ð /‘�˜Ý! "¥lÑ3Ô3ð ØØ$×(Ò(¨°&Ñ9Ô9‘��1Ø�Q‘�Ø˜gÐ%Ð%Ø˜‘F�AØ)*¨A¨�˜WÑ%Ð%Ø#œyˆH�VÑØ"&¤+­dÔ"3×"7Ò"7Õ8QÐSUÑ"VÔ"VˆH�YÑØ'/ˆDÔ$Ð$åØÔ(×,Ò,Ð-LÑMÔMÐSÐQSñô ˆLð Ô=ÀTÐIð 
ØÐ0�t”¨&Ò0ð 	ð ðÕ& t¤}°lÑCÔCØÔ1ñ2ð 2õ ‘”ð	 	õ ,ØŒOØ*Ð4ˆDŒMˆM°ØŒIØ(/Ð9ˆtŒ˜tÔ$Ð$°TØ!Ô2àð˜TÔ?Ð?àØ!5ð

ñ 

ô 

ˆŒð &ð 	%ð 	%ˆAØ$ˆL˜‰OˆOØð 	XØÔ/×AÒAÐBVÑWÔWÐWØIÐI \×%7Ò%7Ñ%9Ô%9ÐIÑIÔIˆØð 	JØHPˆDÔ$Ð%DÑEÐEØ,°Ô0HÐHÐHØÔ(Ð)HÐIå�D”OÐ$4Ô5Ð5Ð5½#ð >
ð >
Ø?C¼}×?SÒ?SÑ?UÔ?Uð>
ñ >
ô >
ñ ;
ô ;
Ð5ðð ð ð ð "œ_Ð-=Ô>½uÔEð	ñ ô ˆOð 8GˆDŒOÐ,Ô-­eÑ4ð ñ (	˜TÔBÑNõ ,¨tÔ/EÅdÔ/KÐKÐKØÔ*­4Ô0Õ1IÔJð Lð Ô&Ð&ð ð	 Ô'ð&ØÔ(ð&åð ØÔ,­TÔ2ðå,¨d¬k½$Ô.?×.CÒ.CÝ0°"ñ/ô /ðð ð&ð &ˆDÔ"ð  $œÐ/AÔB×GÒGÑIÔIÐÝ3ØÔ1Ð3Cñô ˆLð 1AˆDÔ-ð
 (,§{¢{ØÔ5Ý˜Ð3°TÑ:Ô:ØÔ&Ý ¤Ñ0Ô0ØÔ(Øñ(ô (ˆDÔ$ð&ØÔ(ð&åð ØÔ,­TÔ2ðå,¨d¬o¸dÔ.Cðð ð&ð &ˆDÔ"ð ð 	àˆIŒI˜‰NˆIŒIˆIˆIð	ð 	rˆ   c                óô  ‡— | j         r| j        �| j        �| j        €dS t	          | j                             d¦  «        pi ¦  «        }t          | j        |¦  «        | j	        z  Šˆfd„| j         D ¦   «         }|sdS | j
        r| j        }nÅt          ¦   «         }| j        |d<   t          j        t           j        ¦  «                             ¦   «         |d<   t'          | j        t(          di¦  «        }t'          | j        t(          |d         i¦  «        }|                      | j        t-          | dd¦  «        ||ddii ¦  «        | _        || _        i }|D ]4\  }}}	}
|                     ||fg ¦  «                             |	|
f¦  «         Œ5t'          |t6          | j        t:                                        t6          d	¦  «        t(          |t:                   t(                   i¦  «        }|                     ¦   «         D ]|\  \  }}}t?          ||¦  «        }| j         r|                      | j        |||d	¦  «        }n|                      | j        |||¦  «        }| j!        �| j!                             |¦  «         Œ}dS )
u]  Stage stub + accumulated delta writes so final_checkpoint's put
        waits on them (visibility invariant: both must be durable before
        final_checkpoint becomes visible to readers).

        Stub is created lazily â€” only when no persisted parent exists AND at
        least one delta channel has writes that won't be snapshotted.
        Nr¨  c                ó.   •— g | ]\  }}}}|‰v¯||||f‘ŒS rŠ   rŠ   )r‹   r—   rd  r\  r  r¬  s        €r†   r  z5PregelLoop._put_exit_delta_writes.<locals>.<listcomp>Ý  s@   ø€ ð 
ð 
ð 
á"��s˜B ØÐ-Ð-Ð-ð �3˜˜AÐà-Ð-Ð-rˆ   rï   Útsr±  r—   éþÿÿÿrÚ   )"r½   r�   r¶   r´   r•  rÈ   rÛ   r[   rº   r¿   rÁ   rÀ   r\   rÅ   r   Únowr   ÚutcÚ	isoformatr$   r&   r¹   r´  r±  rÇ   r—  rô   r(   r’   r%   r-  r]   rµ   r»   )rá   Úcountersr”  Úanchor_configÚstub_cpÚstub_put_configÚgroupedr—   rd  r\  r  Úanchor_write_configÚentriesÚ	synth_tidr*  r¬  s                  @r†   Ú_put_exit_delta_writesz!PregelLoop._put_exit_delta_writesÅ  sÜ  ø€ ð Ô'ð	àÔ Ð(ØÔ4Ð<ØÔ+Ð3àˆFåØÔ$×(Ò(Ð)HÑIÔIÐOÈRñ
ô 
ˆõ ' t¤}°hÑ?Ô?ØÔ1ñ2ð 	ð

ð 
ð 
ð 
à&*Ô&=ð
ñ 
ô 
ˆð
 ð 	ØˆFàÔ%ð 	3ð !Ô;ˆMˆMå&Ñ(Ô(ˆGØ Ô4ˆG�D‰MÝ$œL­¬Ñ6Ô6×@Ò@ÑBÔBˆG�D‰Må0ØÔ/Ý)¨4Ð0ñô ˆOõ
 /ØÔ/Ý)¨7°4¬=Ð9ñô ˆMð (,§{¢{ØÔ5Ý˜Ð3°TÑ:Ô:ØØØ˜�Øñ(ô (ˆDÔ$ð &3ˆDÔ"ð ACˆØ 'ð 	@ð 	@ÑˆD�#�r˜1Ø×Ò  c˜{¨BÑ/Ô/×6Ò6¸¸A°wÑ?Ô?Ð?Ð?Ý0Øå(¨$¬+µdÔ*;×*?Ò*?Ý,¨bñ+ô +õ )¨-½Ô*=Õ>VÔ*Wð	ñ
ô 
Ðð %,§M¢M¡O¤Oð 	3ð 	3Ñ ‰KˆT�3˜Ý*¨4°Ñ5Ô5ˆIØÔ=ð Ø—k’kØÔ0Ø'ØØØñô ��ð —k’kØÔ0Ø'ØØñ	ô �ð Ô%Ð1ØÔ&×-Ò-¨cÑ2Ô2Ð2øð%	3ð 	3rˆ   Úexc_typeútype[BaseException] | NoneÚ	exc_valueúBaseException | NoneÚ	tracebackúTracebackType | Noneúbool | Nonec                óÆ  ‡— | j         dk    ri| j        r |€t          d„ | j        D ¦   «         ¦  «        rB|                      ¦   «          |                      | j        ¦  «         |                      ¦   «          t          |t          ¦  «        �r²| j        �sª|}|j
        rt          |j
        d         ¦  «        nd}|                      d|¬¦  «         t          | d¦  «        rú| j        rót          d„ | j                             ¦   «         D ¦   «         ¦  «        rÃt%          | j        | j        | j                             ¦   «         | j        | j        ¦  «        }|                     t          | j        t2          ¦  «        r| j        fn| j        ¦  «        sI|                      d	t6          | j        d
„ | j                             ¦   «         D ¦   «         | j        ¦  «         |j
        r|j
        d         s/|j
        r|j
        d         ndŠ|                      dˆfd„¦  «         t9          | j        | j        ¦  «        | _        dS |€!t9          | j        | j        ¦  «        | _        d S d S )Nr  c              3  ó(   K  — | ]}t           |vV — Œd S rú   )r5   )r‹   Úparts     r†   r  z1PregelLoop._suppress_interrupt.<locals>.<genexpr>2  s'   è è € ÐEÐE¨$•6 Ð%ÐEÐEÐEÐEÐEÐErˆ   r   rŠ   rò   rç   rÎ   c              3  ó$   K  — | ]}|j         V — Œd S rú   rW  )r‹   r)  s     r†   r  z1PregelLoop._suppress_interrupt.<locals>.<genexpr>@  s$   è è € ÐDÐD¨˜œÐDÐDÐDÐDÐDÐDrˆ   r"  c                ó&   — g | ]}|j         D ]}|‘ŒŒS rŠ   rW  rX  s      r†   r  z2PregelLoop._suppress_interrupt.<locals>.<listcomp>R  s'   € ÐJÐJÐJ˜qÀÄÐJÐJ¸A˜ÐJÐJÐJÐJrˆ   Úupdatesc                 ó2   •— t          t          ‰ ig¦  «        S rú   )Úiterr4   )Úinterrupt_payloads   €r†   ú<lambda>z0PregelLoop._suppress_interrupt.<locals>.<lambda>Z  s   ø€ �D¥9Ð.?Ð"@Ð!AÑBÔB€ rˆ   T)r®   r¨   r   rÆ   rÎ  rb  rÈ   r/  rÜ   rH   Úargsrß   r÷   r%  rÉ   r#  rÎ   r"  rN   rÃ   rº   r³   r×   r`  r¤   rÄ   r=  rd   re   rÏ   )rá   rÏ  rÑ  rÓ  rò   rè   rÑ   rÞ  s          @r†   Ú_suppress_interruptzPregelLoop._suppress_interrupt%  sŠ  ø€ ð Œ?˜fÒ$Ð$à”ð %ð Ð$åÐEÐE°$Ô2DÐEÑEÔEÑEÔEð %ð ×'Ò'Ñ)Ô)Ð)Ø× Ò  Ô!9Ñ:Ô:Ð:Ø×$Ò$Ñ&Ô&Ð&å�i¥Ñ0Ô0ñ *	I¸¼ñ *	IØ!ˆIØ5>´^ÐK�˜yœ~¨aÔ0Ñ1Ô1Ð1ÈˆJØ×,Ò,¨[ÀZÐ,ÑPÔPÐPõ ˜˜gÑ&Ô&ðàÔ2ðõ ÐDÐD°´
×0AÒ0AÑ0CÔ0CÐDÑDÔDÑDÔDðõ
 $0Ø”OØ”MØ”J×%Ò%Ñ'Ô'ØÔ6ØÔ)ñ$ô $Ð ð (×2Ò2å! $Ô"2µCÑ8Ô8ð*�TÔ%Ð'Ð'àÔ)ñô ð ð
 —J’JØ Ý)ØÔ(ØJÐJ D¤J×$5Ò$5Ñ$7Ô$7ÐJÑJÔJØœñô ð ð ”>ð ¨¬¸Ô):ð Ø9B¼Ð$O I¤N°1Ô$5Ð$5ÈRÐ!Ø—
’
ØØBÐBÐBÐBñô ð õ
 (¨¬°tÔ7GÑHÔHˆDŒKà�4ØÐå'¨¬°tÔ7GÑHÔHˆDŒKˆKˆKð Ðrˆ   r�   ry   r"  úCallable[P, Iterator[Any]]rà  úP.argsÚkwargsúP.kwargsc           
     ó¶  — | j         €d S |dv od| j         j        v }|| j         j        vr|sd S  ||i |¤ŽD ]¢}|| j         j        v r|                       | j        ||f¦  «         |rs|                       | j        d|dk    r
| j        dz
  n| j        t	          j        t          j        ¦  «                             ¦   «         |dk    rdnd|v rdnd|d	œf¦  «         Œ£d S )
N)rN  rÎ   ÚdebugrN  r‚   rÃ   ÚresultÚtask_resultr)  )r—   Ú	timestampÚtypeÚpayload)	r…   r„   rÆ   r—   r   rÃ  r   rÄ  rÅ  )rá   r�   r"  rà  rä  Údebug_remapr  s          r†   r=  zPregelLoop._emitd  s4  € ð Œ;ÐØˆFØÐ6Ð6ÐW¸7ÀdÄkÔFWÐ;WˆØ�t”{Ô(Ð(Ð(°Ð(ØˆFØ�˜Ð( Ð(Ð(ð 	ð 	ˆAØ�t”{Ô(Ð(Ð(Ø—’˜TÔ/°°qÐ9Ñ:Ô:Ð:àð Ø—’àÔ*Øð  $ }Ò4Ð4ð %)¤I°¡M Mà!%¤Ý)1¬µh´lÑ)CÔ)C×)MÒ)MÑ)OÔ)Oà# }Ò4Ð4ð %1 Lð  (¨1˜}˜}ð "/ à!'Ø'(ðð ðñô ð øð	ð 	rˆ   rP  rQ  c               ó˜  ‡‡— | j                              |¦  «        x}�r¨|j        �)t          |j                             dt          ¦  «        v rd S |d         d         t
          k    rü|j        d         t          k    r|j        d         du rd S t
          t          d„ |D ¦   «         ¦  «        igŠ| j	        r| j	        j
        ng }d|v r|                      dˆfd„¦  «         d|v r}t          | j        | j        ¦  «        Št          ‰t           ¦  «        r5‰d         t
                   ‰t
          <   |                      dˆfd	„¦  «         nW|                      dˆfd
„¦  «         n=|d         d         t"          k    r&|                      dt$          | j        ||fg|¦  «         |s(|                      dt&          ||f| j        ¦  «         d S d S d S )NÚtagsr   éÿÿÿÿTc              3  óš   K  — | ]F}|d          t           k    ¯t          |d         t          ¦  «        r|d         n|d         fD ]}|V — ŒŒGdS r  )r4   rÜ   r	   )r‹   r  r  s      r†   r  z+PregelLoop.output_writes.<locals>.<genexpr>˜  sp   è è € ð )ð )à !Ø  œt¥yÒ0Ð0Ý.8¸¸1¼½xÑ.HÔ.HÐ&U a¨¤d dÈqÐQRÌtÈgð  1Ð0Ø !ð à0Ð0Ð0Ð0Ð0ð)ð )rˆ   rÛ  c                 ó"   •— t          ‰ ¦  «        S rú   ©rÝ  rç   s   €r†   rß  z*PregelLoop.output_writes.<locals>.<lambda>¢  s   ø€ µ$°zÑ2BÔ2B€ rˆ   r"  c                 ó$   •— t          ‰ g¦  «        S rú   ró  )Úcurrent_valuess   €r†   rß  z*PregelLoop.output_writes.<locals>.<lambda>¨  s   ø€ µT¸>Ð:JÑ5KÔ5K€ rˆ   c                 ó"   •— t          ‰ ¦  «        S rú   ró  rç   s   €r†   rß  z*PregelLoop.output_writes.<locals>.<lambda>«  s   ø€ µT¸*Ñ5EÔ5E€ rˆ   rÎ   )rÎ   rÛ   r’   rF   r=   r4   r&  r8   rß   r…   r„   r=  re   rº   r¤   rÜ   r•  r1   rc   rk   r¥   )rá   rþ   rÿ   rQ  r)  Ústream_modesrõ  rè   s         @@r†   r'  zPregelLoop.output_writesˆ  s$  øø€ ð ”:—>’> 'Ñ*Ô*Ð*ˆ4ñ /	ØŒ{Ð&­:¸¼¿ºØ�	ñ:ô :ð ,ð ,ð �Ø�aŒy˜Œ|�yÒ(Ð(ð ”9˜Q”<¥4Ò'Ð'¨D¬I°b¬M¸TÐ,AÐ,AØ�Fõ "¥5ð )ð )à%+ð)ñ )ô )ñ $ô $ðð	�
ð 59´KÐG˜tœ{Ô0Ð0ÀR�Ø Ð,Ð,Ø—J’J˜yÐ*BÐ*BÐ*BÐ*BÑCÔCÐCØ˜|Ð+Ð+Ý%2°4´=À$ÔBRÑ%SÔ%S�Nå! .µ$Ñ7Ô7ð GØ4>¸q´MÅ)Ô4L˜¥yÑ1ØŸ
š
 8Ð-KÐ-KÐ-KÐ-KÑLÔLÐLÐLð Ÿ
š
 8Ð-EÐ-EÐ-EÐ-EÑFÔFÐFøØ˜”˜1”¥Ò&Ð&Ø—
’
ØÝ&ØÔ$Ø˜F�^Ð$Øñô ð ð ð Ø—
’
ØÝ*Ø˜6�NØÔ$ñ	ô ð ð ð ðU/	ð /	ðRð rˆ   )*rš   r™   r…   r•   r’   r   r”   r“   r›   rÖ   r�   rœ   rŸ   rž   r¡   r    r£   r¢   r¤   r¢   r¥   r¢   r×   rØ   r®   rt   r¬   r«   r­   r«   rª   r©   rÔ   r·   r°   r¯   r²   r±   rÕ   r¦   r}   r€   )ré   rê   rè   rë   r}   r€   )r}   rø   ©rþ   rÄ   rÿ   r   r}   r€   )r}   r€   rú   ©r)  rv   r0  r–   r1  r2  r}   r3  ©rB  rv   rC  rD  r}   r3  )r}   r¦   ©r}   rf  )rÎ   rk  r}   r€   )r}   r¾   )r£   r¢   rÑ   rÐ   r}   rÐ   )r‰  r   r}   r€   ©rÏ  rÐ  rÑ  rÒ  rÓ  rÔ  r}   rÕ  )
r�   ry   r"  râ  rà  rã  rä  rå  r}   r€   )rþ   rÄ   rÿ   r   rQ  r¦   r}   r€   ) Ú__name__Ú
__module__Ú__qualname__Ú__annotations__r»   r¼   r½   rÁ   rÏ   rÑ   r=   ræ   r÷   rý   r+  r/  rA  rI  rK  rT  re  rh  rj  r>  rS  r†  r¦  rb  rÎ  rá  r=  r'  rŠ   rˆ   r†   r‘   r‘   ž   sÍ  € € € € € € ØÐÐÑØÐÐÑØ!Ð!Ð!Ñ!Ø€I€I�IØ€I€I�IàÐÐÑØ$Ð$Ð$Ñ$Ø,Ð,Ð,Ñ,Ø#Ð#Ð#Ñ#Ø7Ð7Ð7Ñ7Ø#Ð#Ð#Ñ#Ø$Ð$Ð$Ñ$Ø$Ð$Ð$Ñ$ØÐÐÑØ€O€O�OØ<Ð<Ð<Ñ<Ø(Ð(Ð(Ñ(Ø)Ð)Ð)Ñ)ØÐÐÑØ'Ð'Ð'Ñ'Ø$Ð$Ð$Ñ$à1Ð1Ð1Ñ1ØQÐQÐQÑQØ3Ð3Ð3Ñ3ðð ð ñ ð =Ð<Ð<Ñ<Ø€N€N�NØ'Ð'Ð'Ñ'ð +/ÐÐ.Ð.Ð.Ñ.ð 37ÐÐ6Ð6Ð6Ñ6ð BFÐÐEÐEÐEÑEð
 -Ð,Ð,Ñ,ð /Ð.Ð.Ñ.ð #(ÐÐ'Ð'Ð'Ñ'à Ð Ð Ñ ØÐÐÑØÐÐÑØ"Ð"Ð"Ñ"Ø%Ð%Ð%Ñ%Ø+Ð+Ð+Ñ+Ø1Ð1Ð1Ñ1Ø>Ð>Ð>Ñ>Ø1Ð1Ð1Ñ1ðð ð ñ ð ÐÐÑØ*Ð*Ð*Ñ*Ø*.€FÐ.Ð.Ð.Ñ.Ø(,ÐÐ,Ð,Ð,Ñ,Ø7Ð7Ð7Ñ7Ø(Ð(Ð(Ñ(ð( 09Ø09ØCGØBFØ.0Ø+/Ø.3ð-dQð dQð dQð dQð dQð dQðT -/ð	 &ð  &ð  &ð  &ð  &ð  &ðD6ð 6ð 6ð 6ð
]0ð ]0ð ]0ð ]0ð~&ð &ð &ð &ðR OSð%ð %ð %ð %ð %ðN"ð "ð "ð "ð
"ð "ð "ð "ð
Rð Rð Rð Rðh+9ð +9ð +9ð +9ðZ"ð "ð "ð "ð"ð "ð "ð "ð
+ð +ð +ð +ðA;ð A;ð A;ð A;ðF"ð "ð "ð "ð<g ð g ð g ð g ðRJð Jð Jð JðX^3ð ^3ð ^3ð ^3ð@=Ið =Ið =Ið =Ið~"ð "ð "ð "ðJ @Eð2ð 2ð 2ð 2ð 2ð 2ð 2ð 2rˆ   r‘   c                  ó|   ‡ — e Zd Zdeeeeedddddœ
dSˆ fd,„ZdTd5„ZdUd7„Z	 dVdWˆ fd?„ZdXdC„ZdYˆ fdH„Z	dZdJ„Z
d[dR„Zˆ xZS )\ÚSyncPregelLoopNrŠ   F)
rª   r¬   r­   r£   r¤   r¥   rÔ   r°   r²   rÕ   rš   r™   r…   r•   r’   r   r”   r“   r›   rÖ   r�   rœ   rŸ   rž   r¡   r    r×   rØ   r®   rt   rª   r©   r¬   r«   r­   r£   r¢   r¤   r¥   rÔ   r·   r°   r¯   r²   r±   rÕ   r¦   r}   r€   c               óx  •— t          ¦   «                              ||||||||||||||||	|||
|¬¦  «         t          ¦   «         | _        |rM|j        | _        |j        | _        t          |j        ¦  «        j	         
                    d¦  «        d u| _        d S t          | _        d | _        d | _        d| _        d S ©N)r…   r’   r�   r›   r”   rŸ   r¡   r£   r¤   r¥   r¬   r­   rª   rÔ   r×   r°   r²   r®   rÕ   Ú	task_pathF)Úsuperræ   r   Ústackr«  r³   r+  r´   r   Ú
parametersrÛ   rµ   rP   r¶   )rá   rš   r…   r’   r”   r›   r�   rŸ   r¡   r×   r®   rª   r¬   r­   r£   r¤   r¥   rÔ   r°   r²   rÕ   Ú	__class__s                        €r†   ræ   zSyncPregelLoop.__init__¾  së   ø€ õ0 	‰Œ×ÒØØØØ%ØØØØØ!Ø#Ø#Ø+Ø-ØØ1Ø-Ø%Ø%Ø!Ø*Gð) 	ñ 	
ô 	
ð 	
õ, ‘[”[ˆŒ
Øð 	CØ1=Ô1NˆDÔ.Ø+7Ô+BˆDÔ(å˜,Ô1Ñ2Ô2Ô=×AÒAÀ+ÑNÔNØðð Ô:Ð:Ð:õ
 2;ˆDÔ.Ø48ˆDÔ1Ø+/ˆDÔ(Ø=BˆDÔ:Ð:Ð:rˆ   Úprevú concurrent.futures.Future | NonerÃ   r   r‰  r   r¾  r   c                óh  — | j         r.| j         g c}| _         t          j                             |¦  «         	 |�|                     ¦   «          t          t          | j        ¦  «                             ||||¦  «         d S # t          t          | j        ¦  «                             ||||¦  «         w xY wrú   )	r»   Ú
concurrentÚfuturesÚwaitrè  r   r   r�   Úput©rá   r
  r’   rÃ   r‰  r¾  Úfutss          r†   r¶   z/SyncPregelLoop._checkpointer_put_after_previousú  sÀ   € ð Ô!ð 	*Ø+/Ô+AÀ2Ð(ˆD�$Ô(ÝÔ×#Ò# DÑ)Ô)Ð)ð	ØÐØ—’‘”�åÕ$ dÔ&7Ñ8Ô8×<Ò<Ø˜
 H¨lñô ð ð ð ø�DÕ$ dÔ&7Ñ8Ô8×<Ò<Ø˜
 H¨lñô ð ð øøøs   ·A? Á?2B1rf  c                óR  — | j         €dS g }d„ | j                             ¦   «         D ¦   «         x}rv| j                              t	          |¦  «        ¦  «                             ¦   «         D ]<\  }}||         }|j                             |¦  «         |                     |¦  «         Œ=|S )NrŠ   c                ó\   — i | ])}|j         ¯	|j        °|j         j        |j         j        f|“Œ*S rŠ   ©Ú	cache_keyrÿ   ÚnsÚkey©r‹   rY  s     r†   r  z6SyncPregelLoop.match_cached_writes.<locals>.<dictcomp>  óK   € ð 
ð 
ð 
àØŒ{ð
ð $%¤8ð
ØŒ[Œ^˜Qœ[œ_Ð-¨qð
ð 
ð 
rˆ   )	r›   rÎ   r"  rÛ   rß   r-  rÿ   r$  rô   ©rá   ÚmatchedrQ  r  r"  r)  s         r†   rh  z"SyncPregelLoop.match_cached_writes  s¸   € ØŒ:ÐØ�2Ø.0ˆð
ð 
à”Z×&Ò&Ñ(Ô(ð
ñ 
ô 
ð 
ˆ6ð 	%ð
  $œzŸ~š~­e°F©m¬mÑ<Ô<×BÒBÑDÔDð %ð %‘��VØ˜c”{�Ø”×"Ò" 6Ñ*Ô*Ð*Ø—’˜tÑ$Ô$Ð$Ð$Øˆrˆ   r)  rv   r0  r–   r1  r2  r3  c                óÄ   •— t          ¦   «                              |||¦  «        x}r9|                      ¦   «         D ]$}|                      |j        |j        d¬¦  «         Œ%|S ©NTrP  )r  rA  rh  r'  rï   rÿ   ©rá   r)  r0  r1  r@  r	  s        €r†   rA  zSyncPregelLoop.accept_push  sm   ø€ õ ‘W”W×(Ò(¨¨y¸$Ñ?Ô?Ð?ˆ6ð 	FØ×0Ò0Ñ2Ô2ð Fð F�Ø×"Ò" 4¤7¨D¬KÀÐ"ÑEÔEÐEÐEØˆrˆ   rB  rC  rD  c                ó<  — | j         |j                 j        }|sd S | j        r.| j        g c}| _        t          j                             |¦  «         t          |f||| j        | j	        | j         | j
        | j        |j        | j        | j        | j        | j        | j        | j        | j        dœŽ}|€d S || j        |j        <   | j        s|                      |j        |i¦  «         |                      ¦   «         D ]$}|                      |j        |j        d¬¦  «         Œ%|S ©Nrp  TrP  )rŸ   rt  ru  r¼   r  r  r  rR   rÃ   rÉ   rº   rÂ   r’   r—   r˜   r”   r�   rª   r°   r²   rÎ   rï   r§   r>  rh  r'  rÿ   ©rá   rB  rC  ry  r  rz  r)  s          r†   rI  z%SyncPregelLoop.schedule_error_handler$  sG  € ð ”z +Ô"2Ô3ÔFˆØð 	Ø�4àÔ)ð 	*Ø37Ô3QÐSUÐ0ˆD�$Ô0ÝÔ×#Ò# DÑ)Ô)Ð)Ý6Øð
à*ØØ”ØÔ9Ø”jØ”]Ø”LØÔ%Ø”Ø”Ø”*ØÔ*Ø”LØÔ*ØÔ*ð!
ð 
ð 
ˆð$ ÐØ�4Ø&2ˆŒ
�<”?Ñ#ØÔ ð 	UØ×3Ò3°\´_ÀlÐ4SÑTÔTÐTØ×,Ò,Ñ.Ô.ð 	Bð 	BˆDØ×Ò˜tœw¨¬¸DÐÑAÔAÐAÐAØÐrˆ   rþ   rÄ   rÿ   r   c                ó^  •— t          ¦   «                              ||¦  «         |r| j        �t          | d¦  «        sdS | j                             |¦  «        }|�|j        €dS |                      | j        j        |j        j	        |j        j
        f|j        |j        j        fi¦  «         dS )r  NrÎ   )r  r+  r›   r%  rÎ   rÛ   r  r¹   r�  r  r  rÿ   Úttl©rá   rþ   rÿ   r)  r	  s       €r†   r+  zSyncPregelLoop.put_writesI  s´   ø€ å‰Œ×Ò˜7 FÑ+Ô+Ð+Øð 	˜œÐ+µ7¸4ÀÑ3IÔ3IÐ+ØˆFØŒz�~Š~˜gÑ&Ô&ˆØˆ<˜4œ>Ð1ØˆFØ�ŠØŒJŒNà”Ô" D¤NÔ$6Ð7Ø”KØ”NÔ&ð:ðñ	
ô 	
ð 	
ð 	
ð 	
rˆ   r#   c                óˆ  — t          ¦   «         | _        | j        sd }�n| j        t                                        t          ¦  «        r | j                             | j        ¦  «        }nÁ| j        t                                        t          ¦  «        x}rv| 
                    | j        t                                        t          d¦  «        | j        | j        ¦  «        }| j        t                                        t          d ¦  «         n| j                             | j        ¦  «        }|d u| _        |€'t          | j        t!          ¦   «         ddid g ¦  «        }n!| j        �|                      |j        ¦  «         i | j        ¥|j        ¥t          t          di| j                             t          i ¦  «        ¥|j                             t          i ¦  «        ¥i¥| _        | j        | _        |j        | _        |j        d         | _        |j        | _        |j        | _        |j        �d„ |j        D ¦   «         ng | _        g | _        g | _        t;          ¦   «         | _        | j        dk    r	| j        �g nd | _         | j!         "                    tG          | j        ¦  «        ¦  «        | _$        tK          | j&        | j        | j        | j        ¬¦  «        \  | _'        | _(        | j!         )                    | j*        ¦  «         d| _+        | j        d         d	z   | _,        | j,        | j        d
         z   d	z   | _-        | j        d          .                    ¦   «         | _/        |  0                    | j1        | j                             d¦  «        r't;          | j                             d¦  «        ¦  «        nd ¬¦  «        | _2        | S )NrÚ   r—   rÂ  rï   c                ó:   — g | ]\  }}}t          |¦  «        ||f‘ŒS rŠ   ©rÄ   ©r‹   rd  rm  r  s       r†   r  z,SyncPregelLoop.__enter__.<locals>.<listcomp>‘  ó+   € ÐDÐDÐD¡) # q¨!�c�#‰hŒh˜˜1ÐÐDÐDÐDrˆ   r  ©Úsaverr’   rš   r‚   Úrecursion_limitrˆ  rÑ   ©r£   rÑ   )3r   rÒ   r�   rÇ   r%   rÛ   r&   Ú	get_tupler’   r)   Úget_checkpointr(   rc  r+   rÁ   r   r\   r¸   rÃ   rÀ   Úparent_configrË   rÅ   r‰  rÈ   r7  rÉ   r»   r¼   r�  r¿   r®   r½   r  Úenter_contextr_   r¹   rX   r¡   rº   rÂ   Úpushrá  rÌ   r—   r˜   r³  rÊ   r¦  r£   rÑ   ©rá   Úsavedr¤  s      r†   Ú	__enter__zSyncPregelLoop.__enter__]  sŸ  € Ý',¡w¤wˆÔ$ØÔ ð 	HØˆE‰EØÔ#¥DÔ)×-Ò-Õ.FÑGÔGð 	Hð Ô%×/Ò/°Ô0FÑGÔGˆEˆEØ!œ[­Ô.×2Ò2Õ3JÑKÔKÐKˆ\ð 	Hð !×/Ò/Ø”�DÔ!×%Ò%Õ&>ÀÑCÔCØÔ!ØÔ&ñô ˆEð ŒK�Ô×!Ò!Õ"5°tÑ<Ô<Ð<Ð<ð Ô%×/Ò/°Ô0FÑGÔGˆEð
 &+°$Ð%6ˆÔ"Øˆ=Ý#ØÔ&Õ(8Ñ(:Ô(:¸VÀR¸LÈ$ÐPRñô ˆEˆEð Ô%Ð1Ø×$Ò$ UÔ%5Ñ6Ô6Ð6ð"
ØÔ$ð"
àŒlð"
õ Ý(¨"ðàÔ(×,Ò,­T°2Ñ6Ô6ðð ”,×"Ò"¥4¨Ñ,Ô,ðð"
ð "
ˆÔð +/Ô*@ˆÔ'Ø&+Ô&9ˆÔ#Ø#(Ô#3°DÔ#9ˆÔ ØÔ*ˆŒØ#(¤>ˆÔ ð Ô#Ð/ð EÐD¨uÔ/CÐDÑDÔDÐDàð 	Ô&ð
 "$ˆÔØ)+ˆÔ&Ý.1©e¬eˆÔ+à”/ VÒ+Ð+°Ô0AÐ0MˆBˆBÐSWð 	Ôð ”j×.Ò.Õ/AÀ$Ä+Ñ/NÔ/NÑOÔOˆŒÝ&>ØŒJØŒOØÔ#ØÔ)ð	'
ñ '
ô '
Ñ#ˆŒ�t”|ð 	Œ
�Š˜Ô0Ñ1Ô1Ð1ØˆŒØÔ,¨VÔ4°qÑ8ˆŒ	Ø”I ¤Ð,=Ô >Ñ>ÀÑBˆŒ	Ø,0¬OÐ<NÔ,O×,TÒ,TÑ,VÔ,VˆÔ)Ø $§¢Ø”àŒ×"Ò"Ð#5Ñ6Ô6ð�S ¤×!4Ò!4Ð5GÑ!HÔ!HÑIÔIÐIàð	 !,ñ !
ô !
ˆÔð ˆrˆ   rÏ  rÐ  rÑ  rÒ  rÓ  rÔ  rÕ  c                ó:   — | j                              |||¦  «        S rú   )r  Ú__exit__)rá   rÏ  rÑ  rÓ  s       r†   r8  zSyncPregelLoop.__exit__°  s   € ð Œz×"Ò" 8¨Y¸	ÑBÔBÐBrˆ   )*rš   r™   r…   r•   r’   r   r”   r“   r›   rÖ   r�   rœ   rŸ   rž   r¡   r    r×   rØ   r®   rt   rª   r©   r¬   r«   r­   r«   r£   r¢   r¤   r¢   r¥   r¢   rÔ   r·   r°   r¯   r²   r±   rÕ   r¦   r}   r€   )r
  r  r’   r   rÃ   r   r‰  r   r¾  r   r}   r   rû  rú   rù  rú  rø  ©r}   r#   rü  )rý  rþ  rÿ  r=   ræ   r¶   rh  rA  rI  r+  r6  r8  Ú__classcell__©r	  s   @r†   r  r  ½  s,  ø€ € € € € ð DHØ/8Ø09Ø*3Ø+4Ø+4ØBFØ.0Ø+/Ø.3ð-:Cð :Cð :Cð :Cð :Cð :Cð :Cð :Cðxð ð ð ð&ð ð ð ð  OSðð ð ð ð ð ð ð#ð #ð #ð #ðJ
ð 
ð 
ð 
ð 
ð 
ð(Qð Qð Qð QðfCð Cð Cð Cð Cð Cð Cð Crˆ   r  c                  ó|   ‡ — e Zd Zeedeeedddddœ
dSˆ fd,„ZdTd5„ZdUd7„Z	 dVdWˆ fd?„ZdXdC„ZdYˆ fdH„Z	dZdJ„Z
d[dR„Zˆ xZS )\ÚAsyncPregelLoopNrŠ   F)
r¬   r­   rª   r£   r¤   r¥   rÔ   r°   r²   rÕ   rš   r™   r…   r•   r’   r   r”   r“   r›   rÖ   r�   rœ   rŸ   rž   r¡   r    r×   rØ   r®   rt   r¬   r«   r­   rª   r©   r£   r¢   r¤   r¥   rÔ   r·   r°   r¯   r²   r±   rÕ   r¦   r}   r€   c               óx  •— t          ¦   «                              ||||||||||||||||	|||
|¬¦  «         t          ¦   «         | _        |rM|j        | _        |j        | _        t          |j        ¦  «        j	         
                    d¦  «        d u| _        d S t          | _        d | _        d | _        d| _        d S r  )r  ræ   r   r  r«  r³   Úaput_writesr´   r   r  rÛ   rµ   rP   r¶   )rá   rš   r…   r’   r”   r›   r�   rŸ   r¡   r×   r®   r¬   r­   rª   r£   r¤   r¥   rÔ   r°   r²   rÕ   r	  s                        €r†   ræ   zAsyncPregelLoop.__init__»  sí   ø€ õ0 	‰Œ×ÒØØØØ%ØØØØØ!Ø#Ø#Ø+Ø-ØØ1Ø-Ø%Ø%Ø!Ø*Gð) 	ñ 	
ô 	
ð 	
õ, $Ñ%Ô%ˆŒ
Øð 	CØ1=Ô1NˆDÔ.Ø+7Ô+CˆDÔ(å˜,Ô2Ñ3Ô3Ô>×BÒBÀ;ÑOÔOØðð Ô:Ð:Ð:õ
 2;ˆDÔ.Ø48ˆDÔ1Ø+/ˆDÔ(Ø=BˆDÔ:Ð:Ð:rˆ   r
  úasyncio.Task | NonerÃ   r   r‰  r   r¾  r   c              ƒ  óV  K  — | j         r#| j         g c}| _         t          j        |Ž ƒ d {V —† 	 |�|ƒ d {V —† t          t          | j        ¦  «                             ||||¦  «        ƒ d {V —† d S # t          t          | j        ¦  «                             ||||¦  «        ƒ d {V —† w xY wrú   )r»   ÚasyncioÚgatherr   r   r�   Úaputr  s          r†   r¶   z0AsyncPregelLoop._checkpointer_put_after_previous÷  s  è è € ð Ô!ð 	(Ø+/Ô+AÀ2Ð(ˆD�$Ô(Ý”. $Ð'Ð'Ð'Ð'Ð'Ð'Ð'Ð'ð	ØÐØ�
�
�
�
�
�
�
åÕ*¨DÔ,=Ñ>Ô>×CÒCØ˜
 H¨lñô ð ð ð ð ð ð ð ð ð ø•$Õ*¨DÔ,=Ñ>Ô>×CÒCØ˜
 H¨lñô ð ð ð ð ð ð ð ð øøøs   ®
A0 Á08B(rf  c              ƒ  ób  K  — | j         €g S g }d„ | j                             ¦   «         D ¦   «         x}r|| j                              t	          |¦  «        ¦  «        ƒ d {V —†                     ¦   «         D ]<\  }}||         }|j                             |¦  «         |                     |¦  «         Œ=|S )Nc                ó\   — i | ])}|j         ¯	|j        °|j         j        |j         j        f|“Œ*S rŠ   r  r  s     r†   r  z8AsyncPregelLoop.amatch_cached_writes.<locals>.<dictcomp>  r  rˆ   )	r›   rÎ   r"  Úagetrß   r-  rÿ   r$  rô   r  s         r†   rj  z$AsyncPregelLoop.amatch_cached_writes  sÎ   è è € ØŒ:ÐØˆIØ.0ˆð
ð 
à”Z×&Ò&Ñ(Ô(ð
ñ 
ô 
ð 
ˆ6ð 	%ð
 '+¤j§o¢oµe¸F±m´mÑ&DÔ&DÐ DÐ DÐ DÐ DÐ DÐ D×KÒKÑMÔMð %ð %‘��VØ˜c”{�Ø”×"Ò" 6Ñ*Ô*Ð*Ø—’˜tÑ$Ô$Ð$Ð$Øˆrˆ   r)  rv   r0  r–   r1  r2  r3  c              ƒ  óÔ   •K  — t          ¦   «                              |||¦  «        x}r?|                      ¦   «         ƒ d {V —†D ]$}|                      |j        |j        d¬¦  «         Œ%|S r  )r  rA  rj  r'  rï   rÿ   r  s        €r†   Úaaccept_pushzAsyncPregelLoop.aaccept_push  sƒ   øè è € õ ‘W”W×(Ò(¨¨y¸$Ñ?Ô?Ð?ˆ6ð 	FØ"×7Ò7Ñ9Ô9Ð9Ð9Ð9Ð9Ð9Ð9ð Fð F�Ø×"Ò" 4¤7¨D¬KÀÐ"ÑEÔEÐEÐEØˆrˆ   rB  rC  rD  c              ƒ  ó6  K  — | j         |j                 j        }|sd S | j        r#| j        g c}| _        t	          j        |Ž ƒ d {V —† t          |f||| j        | j        | j         | j	        | j
        |j        | j        | j        | j        | j        | j        | j        | j        dœŽ}|€d S || j        |j        <   | j        s|                      |j        |i¦  «         |                      ¦   «         ƒ d {V —†D ]$}|                      |j        |j        d¬¦  «         Œ%|S r!  )rŸ   rt  ru  r¼   rB  rC  rR   rÃ   rÉ   rº   rÂ   r’   r—   r˜   r”   r�   rª   r°   r²   rÎ   rï   r§   r>  rj  r'  rÿ   r"  s          r†   rK  z'AsyncPregelLoop.aschedule_error_handler#  se  è è € ð ”z +Ô"2Ô3ÔFˆØð 	Ø�4àÔ)ð 	(Ø37Ô3QÐSUÐ0ˆD�$Ô0Ý”. $Ð'Ð'Ð'Ð'Ð'Ð'Ð'Ð'Ý6Øð
à*ØØ”ØÔ9Ø”jØ”]Ø”LØÔ%Ø”Ø”Ø”*ØÔ*Ø”LØÔ*ØÔ*ð!
ð 
ð 
ˆð$ ÐØ�4Ø&2ˆŒ
�<”?Ñ#ØÔ ð 	UØ×3Ò3°\´_ÀlÐ4SÑTÔTÐTØ×3Ò3Ñ5Ô5Ð5Ð5Ð5Ð5Ð5Ð5ð 	Bð 	BˆDØ×Ò˜tœw¨¬¸DÐÑAÔAÐAÐAØÐrˆ   rþ   rÄ   rÿ   r   c                óš  •— t          ¦   «                              ||¦  «         |r| j        �t          | d¦  «        sdS | j                             |¦  «        }|�|j        €dS |d         d         t          t          fv rdS |  	                    | j        j
        |j        j        |j        j        f|j        |j        j        fi¦  «         dS )r  NrÎ   r   )r  r+  r›   r%  rÎ   rÛ   r  r4   r1   r¹   Úasetr  r  rÿ   r$  r%  s       €r†   r+  zAsyncPregelLoop.put_writesH  sÑ   ø€ å‰Œ×Ò˜7 FÑ+Ô+Ð+Øð 	˜œÐ+µ7¸4ÀÑ3IÔ3IÐ+ØˆFØŒz�~Š~˜gÑ&Ô&ˆØˆ<˜4œ>Ð1ØˆFØ�!Œ9�QŒ<�I¥uÐ-Ð-Ð-àˆFØ�ŠØŒJŒOà”Ô" D¤NÔ$6Ð7Ø”KØ”NÔ&ð:ðñ	
ô 	
ð 	
ð 	
ð 	
rˆ   r#   c              ƒ  óÈ  K  — t          ¦   «         | _        | j        sd }�n| j        t                                        t          ¦  «        r&| j                             | j        ¦  «        ƒ d {V —†}nÍ| j        t                                        t          ¦  «        x}r|| 
                    | j        t                                        t          d¦  «        | j        | j        ¦  «        ƒ d {V —†}| j        t                                        t          d ¦  «         n%| j                             | j        ¦  «        ƒ d {V —†}|d u| _        |€'t          | j        t!          ¦   «         ddid g ¦  «        }n!| j        �|                      |j        ¦  «         i | j        ¥|j        ¥t          t          di| j                             t          i ¦  «        ¥|j                             t          i ¦  «        ¥i¥| _        | j        | _        |j        | _        |j        d         | _        |j        | _        |j        | _        |j        �d„ |j        D ¦   «         ng | _        g | _        g | _        t;          ¦   «         | _        | j        dk    r	| j        �g nd | _         | j!         "                    tG          | j        ¦  «        ¦  «        ƒ d {V —†| _$        tK          | j&        | j        | j        | j        ¬¦  «        ƒ d {V —†\  | _'        | _(        | j!         )                    | j*        ¦  «         d| _+        | j        d         d	z   | _,        | j,        | j        d
         z   d	z   | _-        | j        d          .                    ¦   «         | _/        |  0                    | j1        | j                             d¦  «        r't;          | j                             d¦  «        ¦  «        nd ¬¦  «        | _2        | S )NrÚ   r—   rÂ  rï   c                ó:   — g | ]\  }}}t          |¦  «        ||f‘ŒS rŠ   r(  r)  s       r†   r  z.AsyncPregelLoop.__aenter__.<locals>.<listcomp>“  r*  rˆ   r  r+  rš   r‚   r-  rˆ  rÑ   r.  )3r   rÒ   r�   rÇ   r%   rÛ   r&   Ú
aget_tupler’   r)   Úaget_checkpointr(   rc  r+   rÁ   r   r\   r¸   rÃ   rÀ   r1  rË   rÅ   r‰  rÈ   r7  rÉ   r»   r¼   r�  r¿   r®   r½   r  Úenter_async_contextr^   r¹   rW   r¡   rº   rÂ   r3  rá  rÌ   r—   r˜   r³  rÊ   r¦  r£   rÑ   r4  s      r†   Ú
__aenter__zAsyncPregelLoop.__aenter___  s(  è è € Ý',¡w¤wˆÔ$ØÔ ð 	OØˆE‰EØÔ#¥DÔ)×-Ò-Õ.FÑGÔGð 	Oð Ô+×6Ò6°tÔ7MÑNÔNÐNÐNÐNÐNÐNÐNˆEˆEØ!œ[­Ô.×2Ò2Õ3JÑKÔKÐKˆ\ð 	Oð '×6Ò6Ø”�DÔ!×%Ò%Õ&>ÀÑCÔCØÔ!ØÔ&ñô ð ð ð ð ð ð ˆEð ŒK�Ô×!Ò!Õ"5°tÑ<Ô<Ð<Ð<ð Ô+×6Ò6°tÔ7MÑNÔNÐNÐNÐNÐNÐNÐNˆEð
 &+°$Ð%6ˆÔ"Øˆ=Ý#ØÔ&Õ(8Ñ(:Ô(:¸VÀR¸LÈ$ÐPRñô ˆEˆEð Ô%Ð1Ø×$Ò$ UÔ%5Ñ6Ô6Ð6ð"
ØÔ$ð"
àŒlð"
õ Ý(¨"ðàÔ(×,Ò,­T°2Ñ6Ô6ðð ”,×"Ò"¥4¨Ñ,Ô,ðð"
ð "
ˆÔð +/Ô*@ˆÔ'Ø&+Ô&9ˆÔ#Ø#(Ô#3°DÔ#9ˆÔ ØÔ*ˆŒØ#(¤>ˆÔ ð Ô#Ð/ð EÐD¨uÔ/CÐDÑDÔDÐDàð 	Ô&ð
 "$ˆÔØ)+ˆÔ&Ý.1©e¬eˆÔ+à”/ VÒ+Ð+°Ô0AÐ0MˆBˆBÐSWð 	Ôð !œJ×:Ò:Ý# D¤KÑ0Ô0ñ
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ˆŒõ -FØŒJØŒOØÔ#ØÔ)ð	-
ñ -
ô -
ð '
ð '
ð '
ð '
ð '
ð '
Ñ#ˆŒ�t”|ð 	Œ
�Š˜Ô0Ñ1Ô1Ð1ØˆŒØÔ,¨VÔ4°qÑ8ˆŒ	Ø”I ¤Ð,=Ô >Ñ>ÀÑBˆŒ	Ø,0¬OÐ<NÔ,O×,TÒ,TÑ,VÔ,VˆÔ)Ø $§¢Ø”àŒ×"Ò"Ð#5Ñ6Ô6ð�S ¤×!4Ò!4Ð5GÑ!HÔ!HÑIÔIÐIàð	 !,ñ !
ô !
ˆÔð ˆrˆ   rÏ  rÐ  rÑ  rÒ  rÓ  rÔ  rÕ  c              ƒ  óÆ   K  — t          j        | j                             |||¦  «        ¦  «        }	 |ƒ d {V —†S # t           j        $ r}g |j        ¢|‘R |_        ‚ d }~ww xY wrú   )rB  Úcreate_taskr  Ú	__aexit__ÚCancelledErrorrà  )rá   rÏ  rÑ  rÓ  Ú	exit_taskÚes         r†   rU  zAsyncPregelLoop.__aexit__´  s…   è è € õ Ô'ØŒJ× Ò  ¨9°iÑ@Ô@ñ
ô 
ˆ	ð	Ø"�?�?�?�?�?�?Ð"øÝÔ%ð 	ð 	ð 	ð *�q”vÐ)˜yÐ)Ð)ˆAŒFØøøøøð		øøøs   ²: ºA Á	AÁA )*rš   r™   r…   r•   r’   r   r”   r“   r›   rÖ   r�   rœ   rŸ   rž   r¡   r    r×   rØ   r®   rt   r¬   r«   r­   r«   rª   r©   r£   r¢   r¤   r¢   r¥   r¢   rÔ   r·   r°   r¯   r²   r±   rÕ   r¦   r}   r€   )r
  r@  r’   r   rÃ   r   r‰  r   r¾  r   r}   r   rû  rú   rù  rú  rø  r9  rü  )rý  rþ  rÿ  r=   ræ   r¶   rj  rI  rK  r+  rR  rU  r:  r;  s   @r†   r=  r=  º  s"  ø€ € € € € ð 09Ø09ØCGØ*3Ø+4Ø+4ØBFØ.0Ø+/Ø.3ð-:Cð :Cð :Cð :Cð :Cð :Cð :Cð :Cðxð ð ð ð*ð ð ð ð  OSðð ð ð ð ð ð ð#ð #ð #ð #ðJ
ð 
ð 
ð 
ð 
ð 
ð.Sð Sð Sð Sðjð ð ð ð ð ð ð rˆ   r=  )r|   rn   r}   rn   )©Ú
__future__r   rB  r:  Úconcurrent.futuresr  Úcollectionsr   r   Úcollections.abcr   r   r   r	   Ú
contextlibr
   r   r   r   r   r   Úinspectr   Útypesr   Útypingr   r   r   r   Úlangchain_core.callbacksr   r   Úlangchain_core.runnablesr   Úlanggraph.cache.baser   Úlanggraph.checkpoint.baser   r   r   r   r   r   r    Úlanggraph.store.baser!   Útyping_extensionsr"   r#   Úlanggraph._internal._configr$   Úlanggraph._internal._constantsr%   r&   r'   r(   r)   r*   r+   r,   r-   r.   r/   r0   r1   r2   r3   r4   r5   r6   r7   r8   r9   r:   Úlanggraph._internal._replayr;   Úlanggraph._internal._scratchpadr<   Úlanggraph._internal._typingr=   r>   Úlanggraph.callbacksr?   r@   rA   Úlanggraph.channels.baserB   Úlanggraph.channels.binoprC   Úlanggraph.channels.deltarD   Ú"langgraph.channels.untracked_valuerE   Úlanggraph.constantsrF   Úlanggraph.errorsrG   rH   Úlanggraph.managed.baserI   rJ   Úlanggraph.pregel._algorK   rL   rM   rN   rO   rP   rQ   rR   rS   rT   rU   rV   Úlanggraph.pregel._checkpointrW   rX   rY   rZ   r[   r\   r]   Úlanggraph.pregel._executorr^   r_   r`   Úlanggraph.pregel._iora   rb   rc   rd   re   Úlanggraph.pregel._messagesrf   Úlanggraph.pregel._readrg   Úlanggraph.pregel._utilsrh   ri   Úlanggraph.pregel.debugrj   rk   rl   Úlanggraph.pregel.protocolrm   rn   Úlanggraph.runtimero   rp   Úlanggraph.typesrq   rr   rs   rt   ru   rv   rw   rx   ry   rz   r{   rß   rÄ   r   r�   r‘   r  r=  rŠ   rˆ   r†   ú<module>r     sq  ðØ "Ð "Ð "Ð "Ð "Ð "à €€€Ø €€€Ø Ð Ð Ð Ø *Ð *Ð *Ð *Ð *Ð *Ð *Ð *Ø AÐ AÐ AÐ AÐ AÐ AÐ AÐ AÐ AÐ AÐ AÐ Aðð ð ð ð ð ð ð ð ð ð ð ð (Ð 'Ð 'Ð 'Ð 'Ð 'Ð 'Ð 'Ø Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð ðð ð ð ð ð ð ð ð ð ð ð ð MÐ LÐ LÐ LÐ LÐ LÐ LÐ LØ 3Ð 3Ð 3Ð 3Ð 3Ð 3Ø *Ð *Ð *Ð *Ð *Ð *ðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð +Ð *Ð *Ð *Ð *Ð *Ø -Ð -Ð -Ð -Ð -Ð -Ð -Ð -à :Ð :Ð :Ð :Ð :Ð :ðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð0 4Ð 3Ð 3Ð 3Ð 3Ð 3Ø <Ð <Ð <Ð <Ð <Ð <Ø :Ð :Ð :Ð :Ð :Ð :Ð :Ð :ðð ð ð ð ð ð ð ð ð ð
 0Ð /Ð /Ð /Ð /Ð /Ø 3Ð 3Ð 3Ð 3Ð 3Ð 3Ø 1Ð 1Ð 1Ð 1Ð 1Ð 1Ø =Ð =Ð =Ð =Ð =Ð =Ø *Ð *Ð *Ð *Ð *Ð *ðð ð ð ð ð ð ð ðð ð ð ð ð ð ð ðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ðð ð ð ð ð ð ð ð ð ð
ð ð ð ð ð ð ð ð ð ð ð ð ð ð :Ð 9Ð 9Ð 9Ð 9Ð 9Ø -Ð -Ð -Ð -Ð -Ð -Ø SÐ SÐ SÐ SÐ SÐ SÐ SÐ Sðð ð ð ð ð ð ð ð ð ð
 BÐ AÐ AÐ AÐ AÐ AÐ AÐ AØ 1Ð 1Ð 1Ð 1Ð 1Ð 1Ð 1Ð 1ð
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð 
ð €GˆC�L„L€Ø€Iˆc�N„N€ð �5˜˜c˜”?Ô
#€ðQð Qð Qð Qð\ð \ð \ð \ð \ñ \ô \ð \ð~(zCð zCð zCð zCð zC�ZÐ!7ñ zCô zCð zCðzJð Jð Jð Jð J�jÐ"=ñ Jô Jð Jð Jð Jrˆ   