OwlCyberSecurity - MANAGER
Edit File: threading.cpython-312.pyc
� ��/i� � �" � d dl Z d dlZd dlmZ d dlmZmZ d dlmZm Z d dl Z d dl m Z d dl mZmZ d dlmZmZmZmZ d dlmZ er7d d lmZ d d lmZ d d lmZ d d lmZ d d lm Z ededef �� Z ede�� Z G d� de � Z d� Z d� Z!d� Z"y)� N��wraps)�Thread�current_thread)�ThreadPoolExecutor�Future)� Integration��use_isolation_scope� use_scope)�event_from_exception�capture_internal_exceptions�logger�reraise)� TYPE_CHECKING)�Any)�TypeVar)�Callable)�Optional)�ExcInfo�F.)�bound�Tc �( � e Zd ZdZdd�Zed� � Zy)�ThreadingIntegration� threadingNc �T � |�t j d� || _ |�|| _ y y )NzLDeprecated: propagate_hub is deprecated. This will be removed in the future.)r �warning�propagate_scope)�self� propagate_hubr s �P/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/threading.py�__init__z ThreadingIntegration.__init__" s4 � � � $� �N�N�^� � /�� � � $�#0�D� � %� c �h ��� t j � ddlm} dd l}|j }t j dk xr |d uxr |dk xr | d uxr | dk\ xr | dk �t �� ��fd�� }|t _ t t j �� t _ y # t $ r d } d }Y ��w xY w)Nr )�VERSION)� � z4.0.0)r' r )� r c �X �� t j � j t � }|� �| g|��i |��S |j r��r@t j dd�� t j � }t j � }nIt j � j � }t j � j � }nd }d }t � 5 t ||t | j d| j � � }|| _ d d d � �| g|��i |��S # 1 sw Y �xY w)NaV There is a known issue with Django channels 2.x and 3.x when using Python 3.8 or older. (Async support is emulated using threads and some Sentry data may be leaked between those threads.) Please either upgrade to Django channels 4.0+, use Django's async features available in Django 3.1+ instead of Django channels, or upgrade to Python 3.9+.� )� stacklevel�__func__)� sentry_sdk� get_client�get_integrationr r �warnings�warn�get_isolation_scope�get_current_scope�forkr � _wrap_run�getattr�run) r �a�kw� integration�isolation_scope� current_scope�new_run� is_async_emulated_with_threads� old_starts ��r" � sentry_startz5ThreadingIntegration.setup_once.<locals>.sentry_startI s �� � %�/�/�1�A�A�BV�W�K��"� ��0��0�R�0�0��*�*�1� �M�M�j� $%� � '1�&D�&D�&F�O�$.�$@�$@�$B�M� '1�&D�&D�&F�&K�&K�&M�O�$.�$@�$@�$B�$G�$G�$I�M�"&�� $� � -�.�#�#�!��D�H�H�j�$�(�(�;��� #��� /� �T�,�A�,��,� ,� /�.�s �4D � D)) r �start�djangor& �channels� __version__� ImportError�sys� version_infor � _wrap_threadpool_executor_submitr �submit)�django_versionrD �channels_versionrA r? r@ s @@r" � setup_oncez ThreadingIntegration.setup_once2 s� �� � �L�L� � $� 8� � '� 3� 3� � � � �v� %� (� ��,� (� �7�*� (� �d�*� (� �&�(� (� ��'� '� �y� �' -� �' -�R $�� �$D� � %� %�'E�% ��!��q � $� !�N� #� � $�s �B! �! B1�0B1)NT)�__name__� __module__� __qualname__� identifierr# � staticmethodrM � r$ r" r r s" � � �J�1� �C � �C r$ r c �6 � ��� t �� �� �fd�� }|S )Nc �� �� �� � ��fd�}��3��1t �� 5 t �� 5 |� cd d d � cd d d � S |� S # 1 sw Y nxY w d d d � y # 1 sw Y y xY w)Nc �v �� t � } �| g�dd ��i ���S # t $ r t t � � Y y w xY w)N� )r � Exceptionr �_capture_exception)r r9 r: � old_run_funcs ���r" �_run_old_run_funcz1_wrap_run.<locals>.run.<locals>._run_old_run_func~ sF �� � /�%�'��#�D�7�1�Q�R�5�7�B�7�7�� � /��+�-�.� /�s � �8�8r )r9 r: r[ �current_scope_to_use�isolation_scope_to_userZ s `` ���r" r8 z_wrap_run.<locals>.run{ sa �� � /� "� -�2F�2R�$�%;�<� � 3�4�,�.� 5�4� =�<� %�&� &� 5�4��4� =�<�<�s! � A �A� A �A � A � A&r )r] r\ rZ r8 s ``` r" r6 r6 y s! �� � �<��'� �'�" �Jr$ c �2 � �� t � � � �fd�� }|S )zB Wrap submit call to propagate scopes on task submission. c � ����� t j � j t � }|� �| �g|��i |��S |j r+� r)t j � �t j � �nU|j rEt j � j � �t j � j � �nd �d ����fd�} �| |g|��i |��S )Nc �� �� ��4��2t �� 5 t �� 5 �| i |��cd d d � cd d d � S �| i |��S # 1 sw Y nxY w d d d � � # 1 sw Y �'xY w)Nr )�args�kwargsr= �fnr< s ���r" � wrapped_fnzK_wrap_threadpool_executor_submit.<locals>.sentry_submit.<locals>.wrapped_fn� se �� � �*�}�/H�(� �9�"�=�1� !�4� 2�6� 2� 2�1� :�9� �t�&�v�&� &� 2�1��1� :�9�9�s! � A�A � A� A �A�A )r. r/ r0 r r r3 r4 r5 ) r rc ra rb r; rd r= r< �funcr? s ` @@��r" � sentry_submitz7_wrap_threadpool_executor_submit.<locals>.sentry_submit� s� �� � !�+�+�-�=�=�>R�S� � � ���b�2�4�2�6�2� 2� � &� &�+I� (� <� <� >�O� &� 8� 8� :�M� � (� (� (� <� <� >� C� C� E�O� &� 8� 8� :� ?� ?� A�M� "�O� �M� '� �D�*�6�t�6�v�6�6r$ r )re r? rf s `` r" rI rI � s# �� � �4�[�7� �7�6 �r$ c �� � t j � } t j � }|j t � �5t | |j ddd��� \ }}t j ||�� | S )Nr F)�type�handled)�client_options� mechanism)�hint) rG �exc_infor. r/ r0 r r �options� capture_event)rm �client�eventrl s r" rY rY � sd � ��|�|�~�H� � "� "� $�F� � � � 2�3�?�*� �!�>�>� *�u�=� � ��t� � � ��T�2� �Or$ )#rG r1 � functoolsr r r r �concurrent.futuresr r r. �sentry_sdk.integrationsr �sentry_sdk.scoper r �sentry_sdk.utilsr r r r �typingr r r r r �sentry_sdk._typesr r r r r6 rI rY rS r$ r" �<module>ry s~ �� � � � ,� 9� � /� ;�� � !��� � � �)���8�C��H�-�.�A���3� �A�W �;� W �t�."�J r$