codekingpro/portable-devtools

1�

2��j[�
�&
�SS
KJ
r
 SSKJrJrJrJr SSKJrJ	r	J3r4 SSKJr SSK
Jr SSKJrJrJrJrJrJrJr SSKJrJrJr SSKJr SS	KJrJr SS5K J!r! SSK"J#r#J$r$J%r% SSK&J'r' \\\(\'-\)/\\%\'-4r*SS
jr+"SS\5r,g)�)
�annotations)�	Awaitable�Callable�Hashable�Sequence)�6isfunction�ismethod�	signature)
�zip_longest)
�FunctionType)�Any�Literal�7NamedTuple�cast�get_args�8get_origin�get_type_hints)�Runnable�RunnableConfig�RunnableLambda)
�RunnableCallable)�END�START)
�InvalidUpdateError)�PASSTHROUGH�ChannelWrite�ChannelWriteEntry)
�Sendc
9
��Sn
Sn[
U[[45(a�[UR5
(d[UR5
(a
URnO�[
URS
S5=
n(a[U5
(aUnO�[UR5
(d[UR5
(a
URnOC[
URS
S5=
n(a[U5
(aUnO[U5
(aUnUb�[U5
=
n(a�[[[[[U55
RR!55
5
nUR#U5
=
n(a'[
U[$5(a[U5
(aUn
U
$![&[(4a U
$f=f
)N�__call__)�10isinstancerrr�funcr	�getattr�afunc�callabler�next�iterr11rr�12parameters�keys�get�type�	TypeError�
StopIteration)�path�input�	callable_�callable_method�hints�first_parameter_name�13input_hints       �]D:\code\apps\devtools\python\user_packages\Python313\site-packages\langgraph/graph/_branch.py�_get_branch_path_input_schemar6)s{
��14
�E�
�15
�		�16�d�-�~�>�?�?��$�)�)�$�$�����(;�(;� �I�I�	�%,�T�Y�Y�17�D�%I�I�/�I�x��P
�P
�,�	��D�J�J�'�'�8�D�J�J�+?�+?� �J�J�	�#*�4�:�:�z�4�#H�H��H��?�+�+�+�	��
�d�^�^��I�� �~�i�/H�&H�e�&H�#'��Y�t�L�)�<�=�H�H�M�M�O�P�$� �#�Y�Y�';�<�<�z�<��j�$�/�/�N�:�4N�4N�&�E��L��
�}�%�

���L�

�s�F*F0�0G�
Gc
���\r
SrS
r%S\S'S\S'SrS\S'\SSS	jj
5rSSS18jj
rSSjr	SSjr19SS
jrSrg)�20BranchSpec�S�(Runnable[Any, Hashable | list[Hashable]]r.zdict[Hashable, str] | None�endsN�type[Any] | None�input_schemac
�t�Sn[
U[5(aUR5nO�[
U[5(aUVs0sHoUU_M nnO�Sn[
U
[[2145(aU
R=
(d U
RnUbt[U
S
S5=
n(a[U5
(aUn[U5
RS5
=
n(a-[U5
[La[U5
Vs0sHoUU_M nnU(a[!U
5
O
Sn	U"XU	S9$s snfs snf![a N1f=f
)Nr �return)r.r;r=)r!�dict�copy�listrrr"r$r#r	rr*rrr�	Exceptionr6)22�clsr.�path_map�infer_schema�	path_map_�namer"�cal�rtn_typer=s23          r5�	from_path�BranchSpec.from_pathXs 
��15�	�	��(�D�)�)�$�M�M�O�	��H�d�+�+�4<�=�H�D�4�Z�H�	�=�	�)-���d�%5�~�$F�G�G��9�9�2��24�25�D��#�&�t�Z��>�>��>�H�S�M�M�"��#1�$�#7�#;�#;�H�#E�E�x�E�%�h�/�7�:�@H��@R�(S�@R��t��@R�I�(S�?K
�4�T�:�PT����<�H�H��'>��)T
���
	��
	�s;�%D*�D*�D �D*�B%D*�7D%�D*� 26D*�*27D7�6
D7c
�
�[R"[URURU
USS
S9UR28(a~[
[U
"UR29R5Vs/sHo3PM snS5UR30R5VVs/sHupC[U5
PM snn55
5$S5$s snfs snnf)NF)r"r$�writer�readerrH�traceT)r�register_writerr�_route�_arouter;rBr�values�items�str)�selfrNrO�
e�las     r5�run�BranchSpec.runzs���31�+�+���[�[��l�l�����

��y�y�

���t�y�y�'7�'7�'9�:�'9�!�A�'9�:�D�A�*.�)�)�/�/�*;�<�*;���S��W�*;�<��
�32�	33� �!34�	35��;��<s�+C�Cc
���U(aFU"U5
n[
U[5(a([
U
[5(aURc0U
E
UE
nOU
nURR	XR5nURXAXb5$�
N)r!r@r=r.�invoke�_finish�rWr/�configrOrN�value�results       r5rR�BranchSpec._route�sr����6�N�E��5�$�'�'��u�d�+�+��%�%�-�*�5�*�E�*����E����!�!�%�0���|�|�F�6�:�:�c�
�
# �U(aFU"U5
n[
U[5(a([
U
[5(aURc0U
E
UE
nOU
nURR	XR5IShv
�NnURXAXb5$N7f
r])r!r@r=r.�ainvoker_r`s       r5rS�BranchSpec._aroute�s}�����6�N�E��5�$�'�'��u�d�+�+��%�%�-�*�5�*�E�*����E��y�y�(�(��7�7���|�|�F�6�:�:�8�s�A.B	
�0
B�1B	
c
��[
U[[45(dU/
nUR(a7UVs/sH)n[
U[5(aUOURUPM+ nnO[[[[-U5n[S
U55
(a[S5
e
[SU55
(a[S5
e
U
"US5nU(dU$SnUH1n	[
U	[5(dMU	R[LdM/Sn O U(a[U5
$[R"XG5 U$s snf)Nc
3
�H# �UHoSL=
(d	 U
[:Hv� M g7f
r])
r)�.0�dests  r5�	<genexpr>�%BranchSpec._finish.<locals>.<genexpr>�s���F���t�|�,�t�u�}�,��s� "
z)Branch did not return a valid destinationc
3
�v# �UH/n
[
U
[5(dMU
R[:Hv� M1 g7f
r])r!r�noder)rk�
ps  r5rmrn�s#���J�l��j��D�6I�}�q�v�v��}�l�s�9
�9
z$Cannot send a packet to the END nodeFT)r!rB�tupler;rrrrV�any�36ValueErrorrrrbrr�do_write)37rWrNr/rcra�
r�destinations�entries�need_passthroughrXs38          r5r_�BranchSpec._finish�s
���&�4��-�0�0��X�F��9�9�DJ�2�DJ�q�Z�
�4�(�(�
�d�i�i�
�l�:�F�
�2�L� ����� 4�f�=�L��F��F�F�F��H�I�I��J�l�J�J�J�$�%K�L�L���u�-����L�$���
��a�!2�3�3��w�w�+�-�+/�(��	�39 �#�G�,�,��%�%�f�6����/2s�0D>�)
F)r.r:rEz&dict[Hashable, str] | list[str] | NonerF�boolr?r8r])rN�_WriterrO�&Callable[[RunnableConfig], Any] | Noner?r)40r/r
rarrOr~rNr}r?r)41rNr}r/r
rcr
rarr?zRunnable | Any)
�__name__�42__module__�__qualname__�__firstlineno__�__annotations__r=�classmethodrKrZrRrSr_�__static_attributes__r{rer5r8r8Ss"
��432�2�44$�$�%)�L�"�)��45#�	I
�6�I
�9�I
��	I
�4647�I
��I
�H
:>�48��49�7�50�51�	52�0;��;��;�537�;��
;�54�;�.;��;��;�557�;��
;�56�;�.!��!��!��	!�57�!�58�
!rer8N)r.z�Callable[..., Hashable | Sequence[Hashable]] | Callable[..., Awaitable[Hashable | Sequence[Hashable]]] | Runnable[Any, Hashable | Sequence[Hashable]]r?r<)-�59__future__r�collections.abcrrrr�inspectrr	r60�	itertoolsr�typesr�typingr
rrrrrr�langchain_core.runnablesrrr�langgraph._internal._runnabler�langgraph.constantsrr�langgraph.errorsr�langgraph.pregel._writerrr�langgraph.typesrrVr|r}r6r8r{rer5�<module>r�
s��


�"�C�C�
�
�61
"��
�
�
�
�
�
�
+�/�P�P� �62�
�c�D�j��4� ��
��
%�&�
(���'
�3�'
��	'
�T
N
��N
re