Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes15kdownloads
callbacks.cpython-313.pyc115 linesDownload Raw Back to __pycache__
1�

2��j�/��X�%SrSSKJr SSKJr SSKJr SSKJrJ	r	J3r4Jr SSKJ
r
 SSKJrJr SSKJrJr SS	KJr SS5KJr Sr\	SrS
\S'\"SS9"SS55r\"SS9"SS55r\\-rS
\S'"SS\5r\"5r S&Sjr!S'Sjr"S(Sjr#S)Sjr$"SS\5r%"SS \5r&\"S\%\&5r'\%\&-\-\-\\-\\-S!-r(S
\S"'S!S#.S*S$jjr)S!S#.S+S%jjr*g!),z�Graph lifecycle callback interfaces and event payloads.6 7This module defines the public callback surface for observing LangGraph-specific8lifecycle transitions such as interrupt and resume.9�)�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_stepsrrT)�frozenc�T�\rSrSr%SrS\S'S\S'S\S'S	\S10'S\S'S
rg)r�*zCGraph lifecycle event emitted when execution pauses for interrupts.�UUID | None�run_idr�status�str�
checkpoint_id�tuple[str, ...]�
checkpoint_nsztuple[Interrupt, ...]�11interrupts�N��__name__�12__module__�__qualname__�__firstlineno__�__doc__�__annotations__�__static_attributes__r)��YD:\code\apps\devtools\python\user_packages\Python313\site-packages\langgraph/callbacks.pyrr*s2��M���?� � �6���B�"�"�F�%�%�<r2rc�H�\rSrSr%SrS\S'S\S'S\S'S	\S13'Srg)
r�>zGGraph lifecycle event emitted when execution resumes from a checkpoint.r!r"rr#r$r%r&r'r)Nr*r)r2r3rr>s)��Q���?� � �3���/�"�"�Fr2rrc�,�\rSrSrSrSSjrSSjrSrg)	r�WaoBase class for graph-level lifecycle callbacks.14 15Subclass this handler to observe graph lifecycle transitions that are16specific to LangGraph execution, rather than generic LangChain runnable17callbacks.18 19Instances can be passed through `config["callbacks"]` when invoking a20graph. Only handlers that inherit from `GraphCallbackHandler` receive these21lifecycle events.22c��g)ztRun when graph execution pauses due to one or more interrupts.23 24Args:25    event: Interrupt lifecycle event payload.26Nr)��self�events  r3�on_interrupt�!GraphCallbackHandler.on_interruptc��r2c��g)zpRun when graph execution resumes from a persisted checkpoint.27 28Args:29    event: Resume lifecycle event payload.30Nr)r9s  r3�	on_resume�GraphCallbackHandler.on_resumejr>r2r)N)r;r�returnr)r;rrBr)r+r,r-r.r/r<r@r1r)r2r3rrWs��	��r2rc�`�UVs/sHn[U[5(dMUPM sn$s snf�N)�31isinstancer)�handlers�hs  r3�_filter_graph_handlersrHus&�� �G�x�!�:�a�1E�#F�A�x�G�G��Gs�+�+c��/n	/n32UbU	RU5 UbU33RU5 [R"UU	U34UUUUUS9 X�lg)N)rF�inheritable_handlers�
parent_run_id�tags�inheritable_tags�metadata�inheritable_metadata)�extendr�__init__r")�managerrFrJrKrLrMrNrOr"�
base_handlers�base_inheritable_handlerss           r3�_init_base_managerrU{se��02�M�;=�������X�&��'�!�(�(�)=�>�� � ���6�#�
�)��1�	��Nr2�_GraphManagerTc��UcU"US9$[X5(aURUS9$[U[[45(a�U"[	UR355[	UR5URURR5URR5URR5URR5US9$[U[5(a�U"[	UR365[	UR5URURR5URR5URR5URR5US9$[U[5(aU"U4US9$[U[[45(d[U[ 5(d[#S5eU"[	[%U55US9$)N�r"�rFrJrKrLrMrNrOr"z1callbacks must be a handler, sequence, or manager)rE�copy�_GraphCallbackManager�_AsyncGraphCallbackManagerrHrFrJrKrLrMrNrOrrr$�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��	37�		38��)�0�1�1��+�I�,>�,>�?�!7�	�8V�8V�!W�#�1�1����$�$�&�&�7�7�<�<�>��'�'�,�,�.�!*�!?�!?�!D�!D�!F��	39�		40��)�1�2�2��I�<��/�/��)�c�5�\�*�*�*�Y��2Q�2Q��K�L�L��%�d�9�o�6�v�F�Fr2c��U[La
URnO%Ub [U[5(d[	S5eUnU"[UR5[UR5URURR5URR5URR5URR5US9$)Nzrun_id must be a UUID or NonerY)�_MISSINGr"rEr41r^rHrFrJrKrLrZrMrNrO)rRrar"�resolved_run_ids    r3�_copy_graph_managerrg�s������!�.�.����j���&>�&>��;�<�<� ���'��(8�(8�9�3�G�4P�4P�Q��+�+�
�\�\�
�
�
 � �1�1�6�6�8��!�!�&�&�(�$�9�9�>�>�@��	�	r2c���\rSrSr%SrS\S'SSSSSSS.SSjjjr\S.SS	jjr\	SSS.SS42jjj5r43SSjrSSjrS
r
g)r[��z+Sync dispatcher for graph lifecycle events.r!r"N�rLrMrNrOr"c�&�[UUUUUUUUUS9	 g�Nrj�rU�	r:rFrJrKrLrMrNrOr"s	         r3rQ�_GraphCallbackManager.__init__��'��	��� ���-��!5��44	45r2rXc�$�[U[U5$rD)rgr[�r:r"s  r3rZ�_GraphCallbackManager.copy�s��46#�4�)>��G�Gr2c��[XUS9$�NrX�rcr`s   r3�	configure�_GraphCallbackManager.configure����*�#��H�Hr2c�4�[URSSU5 g�Nr<�rrFr9s  r3r<�"_GraphCallbackManager.on_interrupts����M�M����		47r2c�4�[URSSU5 g�Nr@r|r9s  r3r@�_GraphCallbackManager.on_resumes����M�M����		48r2r)�NNN�rF�%Sequence[GraphCallbackHandler] | NonerJr�rKr!rL�list[str] | NonerMr�rN�dict[str, Any] | NonerOr�r"r!rB�None)r"�UUID | None | objectrBr[rD)rb�
object | Noner"r!rBr[�r;rrBr��r;rrBr�)r+r,r-r.r/r0rQrerZ�classmethodrwr<r@r1r)r2r3r[r[�s���5���;?�FJ�%)�	49�"&�-1�*.�6:�"�50�7�51�D�52�#�	53��
54�+�55�(�56�4�57��58�59�60�6(0�H�%�H�61�	H��$(�I�#�	I� �I��	I�6263�I��I�64�65r2r[c���\rSrSr%SrS\S'\SSj5rSSSSSSS.SSjjjr\	S	.SS66jjr67\SSS	.SSjjj5rSSjr
SS
jrSrg)r\iz,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_asyncs��r2Nrjc�&�[UUUUUUUUUS9	 grlrmrns	         r3rQ�#_AsyncGraphCallbackManager.__init__#rpr2rXc�$�[U[U5$rD)rgr\rrs  r3rZ�_AsyncGraphCallbackManager.copy;s��68#�4�)C�V�L�Lr2c��[XUS9$rurvr`s   r3rw�$_AsyncGraphCallbackManager.configureBryr2c��P# �[URSSU5IShv�N gN7fr{�r
rFr9s  r3r<�'_AsyncGraphCallbackManager.on_interruptKs'�����M�M����	69�	70�	71���&�$�&c��P# �[URSSU5IShv�N gN7frr�r9s  r3r@�$_AsyncGraphCallbackManager.on_resumeSs'�����M�M����	72�	73�	74�r�r))rB�boolr�r�)r"r�rBr\rD)rbr�r"r!rBr\r�r�)r+r,r-r.r/r0�propertyr�rQrerZr�rwr<r@r1r)r2r3r\r\s��6���
����;?�FJ�%)�	75�"&�-1�*.�6:�"�76�7�77�D�78�#�	79��
80�+�81�(�82�4�83��84�85�86�6(0�M�%�M�87$�	M��$(�I�#�	I� �I��	I�8889$�I��I�90�91r2r\N�GraphCallbacksrXc�H�[RURS5US9$)z�Build a sync graph lifecycle callback manager from a runnable config.92 93This helper filters `config["callbacks"]` down to handlers that inherit94from `GraphCallbackHandler` and binds the provided `run_id` onto the95returned manager.96rbrX)r[rw�get��configr"s  r3rrks+��!�*�*��97�98�;���+��r2c�H�[RURS5US9$)z�Build an async graph lifecycle callback manager from a runnable config.99 100This helper filters `config["callbacks"]` down to handlers that inherit101from `GraphCallbackHandler` and binds the provided `run_id` onto the102returned manager.103rbrX)r\rwr�r�s  r3rr|s+��&�/�/��104�105�;���0��r2)rFzlist[BaseCallbackHandler]rBzlist[GraphCallbackHandler])rRrrFr�rJr�rKr!rLr�rMr�rNr�rOr�r"r!rBr�)ra�type[_GraphManagerT]rbr�r"r!rBrV)rRz2_GraphCallbackManager | _AsyncGraphCallbackManagerrar�r"r�rBrV)r�rr"r!rBr[)r�rr"r!rBr\)+r/�106__future__r�collections.abcr�dataclassesr�typingrrrr	�uuidr107�langchain_core.callbacksrr� langchain_core.callbacks.managerr
r�langchain_core.runnablesr�langgraph.typesr�__all__rr0rrrr�objectrerHrUrcrgr[r\rVr�rrr)r2r3�<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��
��108��>%G�	�%G��%G�
�	%G�109�%G�P�
?��	��
!���	�2;110�/�;111�|@112�!4�@113�F��+�-G���114� �!������"�#�	$�115�#�$�%��
��	������
���	�(����
�� �	r2
codekingpro/portable-devtools · Team Ai