PATH:
opt
/
hc_python
/
lib
/
python3.12
/
site-packages
/
sentry_sdk
/
integrations
/
pydantic_ai
/
patches
/
__pycache__
� o 0i � �� � d dl mZ d dlZd dlmZ ddlmZmZ ddlm Z m Z m Z d dl m Z d dlmZ e r d d l mZmZmZ G d � d � Zdd �Zd� Zd� Zd� Zy# e$ r ed � �w xY w)� ��wrapsN)� DidNotEnable� )�invoke_agent_span�update_invoke_agent_span)�_capture_exception� pop_agent� push_agent)� TYPE_CHECKING)�Agentzpydantic-ai not installed)�Any�Callable�Optionalc �& � e Zd ZdZ dd�Zd� Zd� Zy)� _StreamingContextManagerWrapperzAWrapper for streaming methods that return async context managers.c � � || _ || _ || _ || _ || _ || _ d | _ d | _ d | _ y �N) �agent�original_ctx_manager� user_prompt�model�model_settings� is_streaming�_isolation_scope�_span�_result)�selfr r r r r r s �d/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/pydantic_ai/patches/agent_run.py�__init__z(_StreamingContextManagerWrapper.__init__ sH � � �� �$8��!�&����� � ,��� (��� $�� ��� ��� � c � �� K � t j � | _ | j j � t | j | j | j | j | j � | _ | j j � t | j | j � | j j � � d { ��� }|| _ |S 7 � �wr )� sentry_sdk�isolation_scoper � __enter__r r r r r r r r r � __aenter__r )r �results r r& z*_StreamingContextManagerWrapper.__aenter__+ s� � �� � !+� :� :� <�� � � � �'�'�)� '� � � � �J�J� �J�J� � � � � � � �� � � � � � � � �4�:�:�t� 0� 0�1� �0�0�;�;�=�=�� �� �� � >�s �CC#�C!�C#c � �� K � | j j |||� � d { ��� |�r| j rft | j d� rPt | j d� r| j j nd }| j �t | j |� t � | j r | j j |||� | j r | j j |||� y y 7 ��# t � | j r | j j |||� | j r | j j |||� w w xY w�w)N�output) r � __aexit__r �hasattrr) r r r �__exit__r )r �exc_type�exc_val�exc_tbr) s r r* z)_StreamingContextManagerWrapper.__aexit__D s$ � �� � J��+�+�5�5�h���P� P� P� � �D�L�L�W�T�\�\�8�5T�+2�4�<�<��+J�D�L�L�'�'�PT� � �:�:�)�,�T�Z�Z��@� �K� �z�z�� � �#�#�H�g�v�>� �$�$��%�%�.�.�x��&�I� %�% Q�� �K� �z�z�� � �#�#�H�g�v�>� �$�$��%�%�.�.�x��&�I� %�s/ �E � C= �C;�A8C= � A E �;C= �=A E � E N)T)�__name__� __module__� __qualname__�__doc__r r& r* � r! r r r s � �K� � �(�2Jr! r c �2 � �� t � � �� fd�� }|S )z� Wraps the Agent.run method to create an invoke_agent span. Args: original_func: The original run method is_streaming: Whether this is a streaming method (for future use) c � �@ �K � t j � 5 |j d� xs |r|d nd }|j d� }|j d� }t || ||� � 5 }t | � � � | g|��i |��� d { ��� }t |d� r |j nd }t ||� |t � cd d d � cd d d � S 7 �H# t $ r} t | � | d �d } ~ ww xY w# t � w xY w# 1 sw Y nxY w d d d � y # 1 sw Y y xY w�w)Nr r r r r) ) r# r$ �getr r r+ r) r r � Exceptionr ) r �args�kwargsr r r �spanr' r) �excr � original_funcs ��r �wrapperz$_create_run_wrapper.<locals>.wrapperh s �� �� � � '� '� )� �*�*�]�3�R�4��Q��T�K��J�J�w�'�E� #�Z�Z�(8� 9�N� #��T�5�.�,��� �4� �.� �#0��#G��#G��#G� G�F� /6�f�h�.G�V�]�]�T�F�,�T�6�:�!� �K�)� � *� )� H�� !� (�&�s�+� �4�'��(�� �K��)� �� � *� )� )�s} �D �AD�& C<�4C�C �+C�/ C<�9 D� D � C� C*�C%�%C*�*C-�- C9�9C<�<D �D� D �D�D r )r= r r> s `` r �_create_run_wrapperr? ^ s$ �� � �=�� � � �B �Nr! c �. � � t � � � fd�� }|S )zH Wraps run_stream method that returns an async context manager. c � �� |j d� xs |r|d nd }|j d� }|j d� } �| g|��i |��}t | ||||d�� S )Nr r r r T)r r r r r r )r7 r )r r9 r: r r r r r= s �r r> z*_create_streaming_wrapper.<locals>.wrapper� su �� � �j�j� �/�N�t�D��G�� �� � �7�#�� ���$4�5�� -�T� C�D� C�F� C� � /��!5�#��)� � � r! r �r= r> s ` r �_create_streaming_wrapperrC � s# �� � �=�� � � �( �Nr! c �. � � t � � � fd�� }|S )z� Wraps run_stream_events method - no span needed as it delegates to run(). Note: run_stream_events internally calls self.run() with an event_stream_handler, so the invoke_agent span will be created by the run() wrapper. c � �K � �| g|��i |��2 3 d { ��� }|��� �7 � 6 y # t $ r}t |� |d �d }~ww xY w�wr )r8 r )r r9 r: �eventr< r= s �r r> z1_create_streaming_events_wrapper.<locals>.wrapper� sR �� �� � � ,�T� C�D� C�F� C� �e�� � �� C��� � �s� #��4� �� �s: �A� $ �"� �"�$ �"�$ �A� A �;�A � Ar rB s ` r � _create_streaming_events_wrapperrG � s# �� � �=�� � � � �Nr! c �� � t j } t j }t j }t | d�� t _ t |� t _ t |� t _ y)z� Patches the Agent run methods to create spans for agent execution. This patches both non-streaming (run, run_sync) and streaming (run_stream, run_stream_events) methods. F)r N)r �run� run_stream�run_stream_eventsr? rC rG )� original_run�original_run_stream�original_run_stream_eventss r �_patch_agent_runrO � sU � � �9�9�L� �*�*��!&�!8�!8� � $�L�u�E�E�I� 1�1D�E�E�� >�"� �E�r! )F)� functoolsr r# �sentry_sdk.integrationsr �spansr r �utilsr r r �typingr �pydantic_ai.agentr � ImportErrorr r r r r? rC rG rO r4 r! r �<module>rW so �� � � 0� ?� =� =� �4�'� �.�.�GJ� GJ�T,�^�<�.��k � 4� �2� 3�3�4�s �A �A"
[-] graph_nodes.cpython-312.pyc
[edit]
[-] agent_run.cpython-312.pyc
[edit]
[+]
..
[-] tools.cpython-312.pyc
[edit]
[-] __init__.cpython-312.pyc
[edit]
[-] model_request.cpython-312.pyc
[edit]