📁 File Manager Pro
v10.0.2 | PHP: 8.1.34
Server: LiteSpeed
2026-06-27 20:25:32
📂
/
/
opt
/
hc_python
/
lib
/
python3.12
/
site-packages
/
sentry_sdk
/
integrations
/
grpc
/
__pycache__
✏️
Editing: client.cpython-312.pyc
� Yr*j` � � � d dl mZ d dlZd dlmZmZ d dlmZ d dlm Z d dl m Z erd dl m Z m Z mZmZmZ d dlZd dlmZ d d lmZmZ d d lmZ d d lmZ G d � dej6 ej8 � Z y# e$ r ed � �w xY w)� )� TYPE_CHECKINGN)�OP�SPANDATA)� DidNotEnable)� SPAN_ORIGIN)�has_span_streaming_enabled)�Any�Callable�Iterable�Iterator�Union)�Message)�Call�ClientCallDetails)� _UnaryOutcome)�UnaryStreamCallzgrpcio is not installedc �^ � e Zd Z dd�Z dd�Ze dd�� Zy)�ClientInterceptorc �. � |j }t t j � j � }|r�t j j d|z dt j dt t j |i�� 5 }| j |� } |||� }|j t j |j � j � |cd d d � S t j t j d|z t �� 5 }|j# dd� |j# d|� | j |� } |||� }|j# d |j � j � |cd d d � S # 1 sw Y y xY w# 1 sw Y y xY w) Nzunary unary call to %s� sentry.op� sentry.origin��name� attributes��opr �origin�typez unary unary�method�code)r r � sentry_sdk� get_client�options�traces� start_spanr � GRPC_CLIENTr r � RPC_METHOD�/_update_client_call_details_metadata_from_scope� set_attribute�RPC_RESPONSE_STATUS_CODEr r �set_data��self� continuation�client_call_details�requestr �span_streaming�span�responses �R/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/grpc/client.py�intercept_unary_unaryz'ClientInterceptor.intercept_unary_unary so � � %�+�+��3�J�4I�4I�4K�4S�4S�T�� ��"�"�-�-�-��6� �� � �#�[� �'�'�� � .� � ��H�H�+�� $� (�(;�W�E���"�"� �5�5�x�}�}��7K�7K�� �'� �* �&�&��>�>�-��6�"�� �� � �f�m�4�� � �h��/� �H�H�+�� $� (�(;�W�E��� � �f�h�m�m�o�&:�&:�;� �#� �+� ��*� �s � AE?� A*F �?F� Fc �j � |j }t t j � j � }|rpt j j d|z dt j dt t j |i�� 5 }| j |� } |||� }|cd d d � S t j t j d|z t �� 5 }|j dd� |j d|� | j |� } |||� }|cd d d � S # 1 sw Y y xY w# 1 sw Y y xY w) Nzunary stream call to %sr r r r r z unary streamr )r r r! r" r# r$ r% r r& r r r' r( r+ r, s r4 �intercept_unary_streamz(ClientInterceptor.intercept_unary_streamL s2 � � %�+�+��3�J�4I�4I�4K�4S�4S�T�� ��"�"�-�-�.��7� �� � �#�[� �'�'�� � .� � ��H�H�+�� $� (�(;�W�E�� �%� �( �&�&��>�>�.��7�"�� �� � �f�n�5�� � �h��/� �H�H�+�� $� (�(;�W�E�� �%� �)� ��(� �s � D �A D)� D&�)D2c �t � | j rt | j � ng }t j � j � D ] \ }}|j ||f� � t j j | j | j || j | j | j �� } | S )N)r �timeout�metadata� credentials�wait_for_ready� compression)r: �listr! �get_current_scope� iter_trace_propagation_headers�append�grpc� _interceptor�_ClientCallDetailsr r9 r; r< r= )r/ r: �key�values r4 r( zAClientInterceptor._update_client_call_details_metadata_from_scope s� � � 3F�2N�2N�D�$�-�-� .�TV� � � )� )� +� J� J� L� � � � �O�O�S�%�L� )� M� #� /� /� B� B�&�-�-�'�/�/� �+�7�7�.�=�=�+�7�7� C� �� #�"� N) r- r r. z5Callable[[ClientCallDetails, Message], _UnaryOutcome]r/ r r0 r �returnr ) r- r r. zMCallable[[ClientCallDetails, Message], Union[Iterable[Any], UnaryStreamCall]]r/ r r0 r rH z Union[Iterator[Message], Call])r/ r rH r )�__name__� __module__� __qualname__r5 r7 � staticmethodr( � rG r4 r r s� � �0 �!�0 �M�0 � 1�0 � � 0 � � 0 �d1 �!�1 �e�1 � 1�1 � � 1 � *� 1 �f �#� 0�#� �#� �#rG r ) �typingr r! �sentry_sdk.constsr r �sentry_sdk.integrationsr �#sentry_sdk.integrations.grpc.constsr �sentry_sdk.tracing_utilsr r r r r r rB �google.protobuf.messager r r �grpc._interceptorr �grpc.aio._interceptorr � ImportError�UnaryUnaryClientInterceptor� UnaryStreamClientInterceptorr rM rG r4 �<module>rY so �� � � *� 0� ;� ?��?�?�2��/�,�/�5� #��$�$��%�%�#�� � 2� �0� 1�1�2�s � A5 �5B
💾 Save Changes
❌ Cancel