📁 File Manager Pro
v10.0.2 | PHP: 8.1.34
Server: LiteSpeed
2026-06-27 20:09:02
📂
/
/
opt
/
hc_python
/
lib
/
python3.12
/
site-packages
/
sentry_sdk
/
integrations
/
grpc
/
aio
/
__pycache__
✏️
Editing: client.cpython-312.pyc
� Yr*jf � �� � d dl mZmZmZmZ d dlZd dlmZmZ d dl m Z d dl m Z d dl mZ d dlmZ d dlmZmZmZmZmZmZ G d � d � Z G d � d ee� Z G d� dee� Zy# e$ r e d � �w xY w)� )�Any� AsyncIterable�Callable�UnionN)�OP�SPANDATA)� DidNotEnable)� SPAN_ORIGIN)�has_span_streaming_enabled)�Message)�ClientCallDetails�Metadata�UnaryStreamCall� UnaryStreamClientInterceptor�UnaryUnaryCall�UnaryUnaryClientInterceptorzgrpcio is not installedc �& � e Zd Ze dd�� Zy)�ClientInterceptorc �r � | j �| j t � �� } nIt | j t � s/| j t j | j � �� } t j � j � D ]! \ }}| j j ||� �# | S )N)�metadata) r �_replacer � isinstance� from_tuple� sentry_sdk�get_current_scope� iter_trace_propagation_headers�add)�client_call_details�key�values �V/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/grpc/aio/client.py�/_update_client_call_details_metadata_from_scopezAClientInterceptor._update_client_call_details_metadata_from_scope s� � � � '� '� /�"5�">�">�� �">�"S� �� /� 8� 8�(�C� #6�">�">�!�,�,�-@�-I�-I�J� #?� #� � � )� )� +� J� J� L� � � � � (� (� ,� ,�S�%� 8� M�"�"� N)r r �returnr )�__name__� __module__� __qualname__� staticmethodr" � r# r! r r s$ � ��#� 0�#� �#� �#r# r c �$ � e Zd Z dd�Zy)�!SentryUnaryUnaryClientInterceptorc � �� K � |j }t t j � j � }|r�t j j d|j � z dt j dt t j |j � i�� 5 }| j |� } |||� � d { ��� }|j � � d { ��� }|j t j |j" � |cd d d � S t j t j d|j � z t �� 5 }|j% dd� |j% d|� | j |� } |||� � d { ��� }|j � � d { ��� }|j% d |j" � |cd d d � S 7 ��7 ��# 1 sw Y y xY w7 �T7 �># 1 sw Y y xY w�w) Nzunary unary call to %s� sentry.op� sentry.origin��name� attributes��opr0 �origin�typez unary unary�method�code)r6 r r � get_client�options�traces� start_span�decoder � GRPC_CLIENTr r � RPC_METHODr" r7 � set_attribute�RPC_RESPONSE_STATUS_CODEr0 �set_data) �self� continuationr �requestr6 �span_streaming�span�response� status_codes r! �intercept_unary_unaryz7SentryUnaryUnaryClientInterceptor.intercept_unary_unary- s� � �� � %�+�+��3�J�4I�4I�4K�4S�4S�T�� ��"�"�-�-�-�� � ��?� �� � �#�[� �'�'�� � � � � .� � ��H�H�+�� $� ".�.A�7�!K�K��$,�M�M�O� 3� ��"�"�8�#D�#D�k�FV�FV�W� �%� �( �&�&��>�>�-�� � ��?�"�� �� � �f�m�4�� � �h��/� �H�H�+�� $� ".�.A�7�!K�K��$,�M�M�O� 3� �� � �f�k�&6�&6�7� �%� � L�� 3�� � ��D L�� 3�� � �s� �B G0� G�<G�=G�G�/G�AG0� AG$� G � G$�#G"�$!G$� G0�G�G�G �G0� G$�"G$�$G-�)G0N)rC z6Callable[[ClientCallDetails, Message], UnaryUnaryCall]r r rD r r$ z Union[UnaryUnaryCall, Message])r% r& r' rI r) r# r! r+ r+ , s- � �0 �N�0 � 1�0 � � 0 � *� 0 r# r+ c �$ � e Zd Z dd�Zy)�"SentryUnaryStreamClientInterceptorc � �� K � |j }t t j � j � }|r�t j j d|j � z dt j dt t j |j � i�� 5 }| j |� } |||� � d { ��� }|cd d d � S t j t j d|j � z t �� 5 }|j dd� |j d|� | j |� } |||� � d { ��� }|cd d d � S 7 ��# 1 sw Y y xY w7 � # 1 sw Y y xY w�w) Nzunary stream call to %sr- r. r/ r2 r5 z unary streamr6 )r6 r r r8 r9 r: r; r< r r= r r r> r" rA )rB rC r rD r6 rE rF rG s r! �intercept_unary_streamz9SentryUnaryStreamClientInterceptor.intercept_unary_streamd sZ � �� � %�+�+��3�J�4I�4I�4K�4S�4S�T�� ��"�"�-�-�.�� � � �@� �� � �#�[� �'�'�� � � � � .� � ��H�H�+�� $� ".�.A�7�!K�K�� �!� �$ �&�&��>�>�.�� � � �@�"�� �� � �f�n�5�� � �h��/� �H�H�+�� $� ".�.A�7�!K�K�� �%� � L�� � ��@ L�� � �s\ �B E5� E�<E�=E�AE5�AE)� E'� E)� E5�E�E$� E5�'E)�)E2�.E5N)rC z7Callable[[ClientCallDetails, Message], UnaryStreamCall]r r rD r r$ z*Union[AsyncIterable[Any], UnaryStreamCall])r% r& r' rM r) r# r! rK rK ` s- � �. �O�. � 1�. � � . � 6� . r# rK ) �typingr r r r r �sentry_sdk.constsr r �sentry_sdk.integrationsr �#sentry_sdk.integrations.grpc.constsr �sentry_sdk.tracing_utilsr �google.protobuf.messager �grpc.aior r r r r r � ImportErrorr r+ rK r) r# r! �<module>rV su �� 6� 6� � *� 0� ;� ?� 2�/�� �#� #�*1 �(9�;V� 1 �h2 �� �2 ��[ � 2� �0� 1�1�2�s �A% �%A3
💾 Save Changes
❌ Cancel