ó
    ýÞ jæ/  ã                  óX  • % S r SSKJr  SSKJr  SSKJr  SSKJrJ	r	J
r
Jr  SSKJr  SSKJrJr  SSKJrJr  SS	KJr  SS
KJr  Sr\	S   rS\S'    \" SS9 " S S5      5       r\" SS9 " S S5      5       r\\-  rS\S'     " S S\5      r\" 5       r     S&S jr!                    S'S jr"        S(S jr#        S)S jr$ " S S\5      r% " S S \5      r&\" S\%\&5      r'\%\&-  \-  \-  \\   -  \\   -  S!-  r(S\S"'   S!S#.     S*S$ jjr)S!S#.     S+S% jjr*g!),z¾Graph lifecycle callback interfaces and event payloads.

This module defines the public callback surface for observing LangGraph-specific
lifecycle transitions such as interrupt and resume.
é    )Úannotations)ÚSequence)Ú	dataclass)ÚAnyÚLiteralÚ	TypeAliasÚTypeVar)ÚUUID)ÚBaseCallbackHandlerÚBaseCallbackManager)Úahandle_eventÚhandle_event)ÚRunnableConfig)Ú	Interrupt)ÚGraphCallbackHandlerÚGraphInterruptEventÚGraphLifecycleEventÚGraphLifecycleStatusÚGraphResumeEventÚ+get_async_graph_callback_manager_for_configÚ*get_sync_graph_callback_manager_for_config)ÚinputÚpendingÚdoneÚinterrupt_beforeÚinterrupt_afterÚout_of_stepsr   r   T)Úfrozenc                  óT   • \ rS rSr% SrS\S'    S\S'    S\S'    S	\S
'    S\S'   Srg)r   é*   zCGraph lifecycle event emitted when execution pauses for interrupts.úUUID | NoneÚrun_idr   ÚstatusÚstrÚcheckpoint_idútuple[str, ...]Úcheckpoint_nsztuple[Interrupt, ...]Ú
interrupts© N©Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__Ú__annotations__Ú__static_attributes__r)   ó    ÚM/var/www/html/gaurav/venv/lib/python3.13/site-packages/langgraph/callbacks.pyr   r   *   s2   ‡ áMàÓØ?à Ó Ø6àÓØBà"Ó"ØFà%Ó%Ú<r2   r   c                  óH   • \ rS rSr% SrS\S'    S\S'    S\S'    S	\S
'   Srg)r   é>   zGGraph lifecycle event emitted when execution resumes from a checkpoint.r!   r"   r   r#   r$   r%   r&   r'   r)   Nr*   r)   r2   r3   r   r   >   s)   ‡ áQàÓØ?à Ó Ø3àÓØ/à"Ó"ÚFr2   r   r   c                  ó,   • \ rS rSrSrSS jrSS jrSrg)	r   éW   ao  Base class for graph-level lifecycle callbacks.

Subclass this handler to observe graph lifecycle transitions that are
specific to LangGraph execution, rather than generic LangChain runnable
callbacks.

Instances can be passed through `config["callbacks"]` when invoking a
graph. Only handlers that inherit from `GraphCallbackHandler` receive these
lifecycle events.
c                ó   • g)ztRun when graph execution pauses due to one or more interrupts.

Args:
    event: Interrupt lifecycle event payload.
Nr)   ©ÚselfÚevents     r3   Úon_interruptÚ!GraphCallbackHandler.on_interruptc   ó   � r2   c                ó   • g)zpRun when graph execution resumes from a persisted checkpoint.

Args:
    event: Resume lifecycle event payload.
Nr)   r9   s     r3   Ú	on_resumeÚGraphCallbackHandler.on_resumej   r>   r2   r)   N)r;   r   Úreturnr   )r;   r   rB   r   )r+   r,   r-   r.   r/   r<   r@   r1   r)   r2   r3   r   r   W   s   † ñ	ô÷r2   r   c                ó^   • U  Vs/ sH  n[        U[        5      (       d  M  UPM     sn$ s  snf ©N)Ú
isinstancer   )ÚhandlersÚhs     r3   Ú_filter_graph_handlersrH   u   s&   € ñ  ÓG‘x�!¤:¨aÔ1E×#F�A‘xÑGÐGùÒGs   …*¡*c               óž   • / n	/ n
Ub  U	R                  U5        Ub  U
R                  U5        [        R                  " U U	U
UUUUUS9  X€l        g )N)rF   Úinheritable_handlersÚparent_run_idÚtagsÚinheritable_tagsÚmetadataÚinheritable_metadata)Úextendr   Ú__init__r"   )ÚmanagerrF   rJ   rK   rL   rM   rN   rO   r"   Úbase_handlersÚbase_inheritable_handlerss              r3   Ú_init_base_managerrU   {   se   € ð 02€MØ;=ÐØÑØ×Ñ˜XÔ&ØÑ'Ø!×(Ñ(Ð)=Ô>Ü× Ò ØØØ6Ø#ØØ)ØØ1ò	ð …Nr2   Ú_GraphManagerTc               ó  • Uc  U " US9$ [        X5      (       a  UR                  US9$ [        U[        [        45      (       a�  U " [	        UR
                  5      [	        UR                  5      UR                  UR                  R                  5       UR                  R                  5       UR                  R                  5       UR                  R                  5       US9$ [        U[        5      (       a�  U " [	        UR
                  5      [	        UR                  5      UR                  UR                  R                  5       UR                  R                  5       UR                  R                  5       UR                  R                  5       US9$ [        U[        5      (       a  U " U4US9$ [        U[        [        45      (       d  [        U[         5      (       d  [#        S5      eU " [	        [%        U5      5      US9$ )N©r"   ©rF   rJ   rK   rL   rM   rN   rO   r"   z1callbacks must be a handler, sequence, or manager)rE   ÚcopyÚ_GraphCallbackManagerÚ_AsyncGraphCallbackManagerrH   rF   rJ   rK   rL   rM   rN   rO   r   r   r$   Úbytesr   Ú	TypeErrorÚlist©ÚclsÚ	callbacksr"   s      r3   Ú_configure_graph_callbacksrc   š   sª  € ð ÑÙ˜&Ñ!Ð!Ü�)×!Ñ!Ø�~‰~ Vˆ~Ð,Ð,Ü�)Ô3Ô5OÐP×QÑQáÜ+¨I×,>Ñ,>Ó?Ü!7¸	×8VÑ8VÓ!WØ#×1Ñ1Ø—‘×$Ñ$Ó&Ø&×7Ñ7×<Ñ<Ó>Ø×'Ñ'×,Ñ,Ó.Ø!*×!?Ñ!?×!DÑ!DÓ!FØñ	
ð 		
ô �)Ô0×1Ñ1ÙÜ+¨I×,>Ñ,>Ó?Ü!7¸	×8VÑ8VÓ!WØ#×1Ñ1Ø—‘×$Ñ$Ó&Ø&×7Ñ7×<Ñ<Ó>Ø×'Ñ'×,Ñ,Ó.Ø!*×!?Ñ!?×!DÑ!DÓ!FØñ	
ð 		
ô �)Ô1×2Ñ2Ù�I�<¨Ñ/Ð/Ü�)œc¤5˜\×*Ñ*´*¸YÌ×2QÑ2QÜÐKÓLÐLÙÔ%¤d¨9£oÓ6¸vÑFÐFr2   c                ó²  • U[         L a  U R                  nO%Ub   [        U[        5      (       d  [	        S5      eUnU" [        U R                  5      [        U R                  5      U R                  U R                  R                  5       U R                  R                  5       U R                  R                  5       U R                  R                  5       US9$ )Nzrun_id must be a UUID or NonerY   )Ú_MISSINGr"   rE   r
   r^   rH   rF   rJ   rK   rL   rZ   rM   rN   rO   )rR   ra   r"   Úresolved_run_ids       r3   Ú_copy_graph_managerrg   Â   s³   € ð ”ÒØ!Ÿ.™.‰àÑ¤j°¼×&>Ñ&>ÜÐ;Ó<Ð<Ø ˆáÜ'¨×(8Ñ(8Ó9Ü3°G×4PÑ4PÓQØ×+Ñ+Ø�\‰\×ÑÓ Ø ×1Ñ1×6Ñ6Ó8Ø×!Ñ!×&Ñ&Ó(Ø$×9Ñ9×>Ñ>Ó@Øñ	ð 	r2   c                  óÂ   • \ rS rSr% SrS\S'      SSSSSSS.                 SS jjjr\S.   SS	 jjr\	 SSS.     SS
 jjj5       r
SS jrSS jrSrg)r[   éÛ   z+Sync dispatcher for graph lifecycle events.r!   r"   N©rL   rM   rN   rO   r"   c               ó&   • [        U UUUUUUUUS9	  g ©Nrj   ©rU   ©	r:   rF   rJ   rK   rL   rM   rN   rO   r"   s	            r3   rQ   Ú_GraphCallbackManager.__init__à   ó'   € ô 	ØØØ ØØØ-ØØ!5Øó
	
r2   rX   c               ó$   • [        U [        U5      $ rD   )rg   r[   ©r:   r"   s     r3   rZ   Ú_GraphCallbackManager.copyø   s   € ô
 # 4Ô)>ÀÓGÐGr2   c               ó   • [        XUS9$ ©NrX   ©rc   r`   s      r3   Ú	configureÚ_GraphCallbackManager.configureÿ   ó   € ô *¨#ÀÑHÐHr2   c                ó4   • [        U R                  SS U5        g ©Nr<   ©r   rF   r9   s     r3   r<   Ú"_GraphCallbackManager.on_interrupt  s   € ÜØ�M‰MØØØõ		
r2   c                ó4   • [        U R                  SS U5        g ©Nr@   r|   r9   s     r3   r@   Ú_GraphCallbackManager.on_resume  s   € ÜØ�M‰MØØØõ		
r2   r)   ©NNN©rF   ú%Sequence[GraphCallbackHandler] | NonerJ   rƒ   rK   r!   rL   úlist[str] | NonerM   r„   rN   údict[str, Any] | NonerO   r…   r"   r!   rB   ÚNone)r"   úUUID | None | objectrB   r[   rD   )rb   úobject | Noner"   r!   rB   r[   ©r;   r   rB   r†   ©r;   r   rB   r†   )r+   r,   r-   r.   r/   r0   rQ   re   rZ   Úclassmethodrw   r<   r@   r1   r)   r2   r3   r[   r[   Û   sú   ‡ Ù5àÓð ;?ØFJØ%)ð	
ð "&Ø-1Ø*.Ø6:Ø"ñ
à7ð
ð Dð
ð #ð	
ð ð
ð +ð
ð (ð
ð 4ð
ð ð
ð 
ö
ð6 (0ñHð %ðHð 
õ	Hð ð $(ðIð #ñ	Ià ðIð ð	Ið
 
õIó ðIô
÷
r2   r[   c                  óÖ   • \ rS rSr% SrS\S'   \SS j5       r   SSSSSSS.                 SS jjjr\	S	.   SS
 jjr
\ SSS	.     SS jjj5       rSS jrSS jrSrg)r\   i  z,Async dispatcher for graph lifecycle events.r!   r"   c                ó   • g)z$Return whether the manager is async.Tr)   )r:   s    r3   Úis_asyncÚ#_AsyncGraphCallbackManager.is_async  s   € ð r2   Nrj   c               ó&   • [        U UUUUUUUUS9	  g rl   rm   rn   s	            r3   rQ   Ú#_AsyncGraphCallbackManager.__init__#  rp   r2   rX   c               ó$   • [        U [        U5      $ rD   )rg   r\   rr   s     r3   rZ   Ú_AsyncGraphCallbackManager.copy;  s   € ô
 # 4Ô)CÀVÓLÐLr2   c               ó   • [        XUS9$ ru   rv   r`   s      r3   rw   Ú$_AsyncGraphCallbackManager.configureB  ry   r2   c              ƒ  óP   #   • [        U R                  SS U5      I S h  v•N   g  N7fr{   ©r   rF   r9   s     r3   r<   Ú'_AsyncGraphCallbackManager.on_interruptK  s'   é € ÜØ�M‰MØØØó	
÷ 	
ó 	
ùó   ‚&ž$Ÿ&c              ƒ  óP   #   • [        U R                  SS U5      I S h  v•N   g  N7fr   r—   r9   s     r3   r@   Ú$_AsyncGraphCallbackManager.on_resumeS  s'   é € ÜØ�M‰MØØØó	
÷ 	
ó 	
ùr™   r)   )rB   Úboolr�   r‚   )r"   r‡   rB   r\   rD   )rb   rˆ   r"   r!   rB   r\   r‰   rŠ   )r+   r,   r-   r.   r/   r0   ÚpropertyrŽ   rQ   re   rZ   r‹   rw   r<   r@   r1   r)   r2   r3   r\   r\     s  ‡ Ù6àÓàóó ðð ;?ØFJØ%)ð	
ð "&Ø-1Ø*.Ø6:Ø"ñ
à7ð
ð Dð
ð #ð	
ð ð
ð +ð
ð (ð
ð 4ð
ð ð
ð 
ö
ð6 (0ñMð %ðMð 
$õ	Mð ð $(ðIð #ñ	Ià ðIð ð	Ið
 
$õIó ðIô
÷
r2   r\   NÚGraphCallbacksrX   c               óH   • [         R                  U R                  S5      US9$ )zæBuild a sync graph lifecycle callback manager from a runnable config.

This helper filters `config["callbacks"]` down to handlers that inherit
from `GraphCallbackHandler` and binds the provided `run_id` onto the
returned manager.
rb   rX   )r[   rw   Úget©Úconfigr"   s     r3   r   r   k  s+   € ô !×*Ñ*Ø�
‰
�;ÓØð +ð ð r2   c               óH   • [         R                  U R                  S5      US9$ )zèBuild an async graph lifecycle callback manager from a runnable config.

This helper filters `config["callbacks"]` down to handlers that inherit
from `GraphCallbackHandler` and binds the provided `run_id` onto the
returned manager.
rb   rX   )r\   rw   r    r¡   s     r3   r   r   |  s+   € ô &×/Ñ/Ø�
‰
�;ÓØð 0ð ð r2   )rF   zlist[BaseCallbackHandler]rB   zlist[GraphCallbackHandler])rR   r   rF   rƒ   rJ   rƒ   rK   r!   rL   r„   rM   r„   rN   r…   rO   r…   r"   r!   rB   r†   )ra   útype[_GraphManagerT]rb   rˆ   r"   r!   rB   rV   )rR   z2_GraphCallbackManager | _AsyncGraphCallbackManagerra   r¤   r"   r‡   rB   rV   )r¢   r   r"   r!   rB   r[   )r¢   r   r"   r!   rB   r\   )+r/   Ú
__future__r   Úcollections.abcr   Údataclassesr   Útypingr   r   r   r	   Úuuidr
   Úlangchain_core.callbacksr   r   Ú langchain_core.callbacks.managerr   r   Úlangchain_core.runnablesr   Úlanggraph.typesr   Ú__all__r   r0   r   r   r   r   Úobjectre   rH   rU   rc   rg   r[   r\   rV   rž   r   r   r)   r2   r3   Ú<module>r°      sg  ðòõ #å $Ý !ß 3Ó 3Ý ç Mß HÝ 3å %ð€ð #*ðñ#Ð �ió ð Nñ �$Ñ÷=ð =ó ð=ñ& �$Ñ÷Gð Gó ðGð  "5Ð7GÑ!GÐ �YÓ GðôÐ.ô ñ6 ‹8€ðHØ'ðHàôHðØ ðà3ðð @ðð ð	ð ðð 'ðð $ðð 0ðð ðð 
ôð>%GØ	ð%Gàð%Gð ð	%Gð
 ô%GðPØ?ðà	ðð !ðð ô	ô2;
Ð/ô ;
ô|@
Ð!4ô @
ñF ØÐ+Ð-Gó€ð
 Ø ñ!àñð ñð Ð"Ñ#ñ	$ð
 Ð#Ñ$ñ%ð ñð �	ó ð ñØðð ðð õ	ð( ñØðð ðð  ö	r2   