관리-도구
편집 파일: rq.cpython-311.pyc
� �܋f# � �J � d dl mZ d dlZd dlmZ d dlmZ d dlmZ d dl m Z m Z d dl m Z d dlmZ d d lmZmZmZmZ d d lmZ d d lmZ d d lmZ d d l m Z n# e $ r e d� � �w xY wd dl m Z e r d dl!m"Z"m#Z#m$Z$ d dl m%Z% d dlm&Z& d dl'm(Z( G d� de � � Z)d� Z*d� Z+dS )� )�absolute_importN)�OP)�continue_trace)�Hub)� DidNotEnable� Integration)� ignore_logger)�TRANSACTION_SOURCE_TASK)�capture_internal_exceptions�event_from_exception�format_timestamp� parse_version)�Queue)�JobTimeoutException)�VERSION)�WorkerzRQ not installed)� TYPE_CHECKING)�Any�Callable�Dict)�EventProcessor)�ExcInfo)�Jobc �( � e Zd ZdZed� � � ZdS )� RqIntegration�rqc �| ���� t t � � } | �'t d� t � � � � �| dk rt d� � �t j ��fd�}|t _ t j ��fd�}|t _ t j ��fd�}|t _ t d� � d S )NzUnparsable RQ version: {})r � z RQ 0.6 or newer is required.c � �� t j }|� t � � }|� � | |g|�R i |��S |j }|�J �|� � � 5 }|� � � |� t t j |� � � � � � t |j � d� � pi t j dt �� � }t# � � 5 |j |_ d d d � � n # 1 swxY w Y |� |d|i�� � 5 � | |g|�R i |��} d d d � � n # 1 swxY w Y d d d � � n # 1 swxY w Y | j r|� � � | S )N�_sentry_trace_headerszunknown RQ task)�op�name�source�rq_job)�custom_sampling_context)r �current�get_integrationr �client� push_scope�clear_breadcrumbs�add_event_processor�_make_event_processor�weakref�refr �meta�getr � QUEUE_TASK_RQr r � func_namer" �start_transaction�is_horse�flush) �self�job�args�kwargs�hub� integrationr( �scope� transaction�rv�old_perform_jobs ��Q/opt/cloudlinux/venv/lib64/python3.11/site-packages/sentry_sdk/integrations/rq.py�sentry_patched_perform_jobz<RqIntegration.setup_once.<locals>.sentry_patched_perform_job6 sv �� ��+�C� �-�-�m�<�<�K��"�&��t�S�B�4�B�B�B�6�B�B�B��Z�F��%�%�%�� � �!�!� E�U��'�'�)�)�)��)�)�*?�� �C�@P�@P�*Q�*Q�R�R�R� ,��H�L�L�!8�9�9�?�R��'�*�2� � � � � 1�2�2� 5� 5�'*�}�K�$�5� 5� 5� 5� 5� 5� 5� 5� 5� 5� 5���� 5� 5� 5� 5� �*�*� �(�C� � +� � � E� E� )� ��s�D�T�D�D�D�V�D�D�B�E� E� E� E� E� E� E� E� E� E� E���� E� E� E� E� E� E� E� E� E� E� E� E� E� E� E���� E� E� E� E�& �}� � � � �����Is[ �BE�) D�6 E�D �E� D � E�&E �4 E� E �E�E �E�E� Ec �J �� |j rt |� � �| |g|�R i |��S )N)� is_failed�_capture_exception)r6 r7 �exc_infor9 �old_handle_exceptions �r@ � sentry_patched_handle_exceptionzARqIntegration.setup_once.<locals>.sentry_patched_handle_exception` s> �� ��}� -�"�8�,�,�,�'�'��c�G�H�G�G�G��G�G� G� c �� �� t j }|� t � � �5|j j �)t |� � � � � |j d< �| |fi |��S )Nr ) r r& r' r r< �span�dict� iter_trace_propagation_headersr/ )r6 r7 r9 r: �old_enqueue_jobs �r@ �sentry_patched_enqueue_jobz<RqIntegration.setup_once.<locals>.sentry_patched_enqueue_jobk sj �� ��+�C��"�"�=�1�1�=��9�>�-�8<��:�:�<�<�9� 9�C�H� 4�5� #�?�4��7�7��7�7� 7rH z rq.worker) r � RQ_VERSIONr �formatr � perform_job�handle_exceptionr � enqueue_jobr )�versionrA rG rN rM rF r? s @@@r@ � setup_oncezRqIntegration.setup_once( s� ���� � � �+�+�� �?� � :� A� A�*� M� M�N�N� N� �V� � � � =�>�>� >� �,��$ � $ � $ � $ � $ �L 8��� %� 6� � H� H� H� H� H� #B�� � �+�� 8� 8� 8� 8� 8� 7����k�"�"�"�"�"rH N)�__name__� __module__� __qualname__� identifier� staticmethodrU � rH r@ r r % s7 � � � � � ��J��O#� O#� �\�O#� O#� O#rH r c � � � � fd�}|S )Nc � �� �� � }|��t � � 5 | � di � � }|j |j |j |j |j d�|d< |j r t |j � � |d d< |j r t |j � � |d d< d d d � � n # 1 swxY w Y d|v rTt � � 5 t |d d t � � r dd |j g| d < d d d � � n # 1 swxY w Y | S ) N�extra)�job_id�funcr8 r9 � descriptionzrq-job� enqueued_at� started_atrE r r r � fingerprint) r � setdefault�idr2 r8 r9 ra rb r rc � issubclassr )�event�hintr7 r^ �weak_jobs �r@ �event_processorz._make_event_processor.<locals>.event_processor} s� �� ��h�j�j�� �?�,�.�.� U� U� �(�(��"�5�5�� !�f� �M� �H� !�j�#&�?� #� #��h�� �?� W�5E�c�o�5V�5V�E�(�O�M�2��>� U�4D�S�^�4T�4T�E�(�O�L�1� U� U� U� U� U� U� U� U� U� U� U���� U� U� U� U� �� � �,�.�.� X� X� �d�:� .�q� 1�3F�G�G� X�,0�2G�� �+W�E�-�(� X� X� X� X� X� X� X� X� X� X� X���� X� X� X� X� � s$ �BB+�+B/�2B/�/D�D� Dr[ )rj rk s ` r@ r, r, { s$ �� �� � � � �4 �rH c �� � t j }|� t � � �d S |j }t | |j ddd��� � \ }}|� ||�� � d S )Nr F)�type�handled)�client_options� mechanism)ri )r r& r' r r( r �options� capture_event)rE r9 r: r( rh ri s r@ rD rD � sw � � �+�C� ���=�)�)�1��� �Z�F�&�� �~� �E�2�2�� � �K�E�4� ���e�$��'�'�'�'�'rH ),� __future__r r- �sentry_sdk.constsr �sentry_sdk.apir �sentry_sdk.hubr �sentry_sdk.integrationsr r � sentry_sdk.integrations.loggingr �sentry_sdk.tracingr �sentry_sdk.utilsr r r r �rq.queuer � rq.timeoutsr � rq.versionr rO � rq.workerr � ImportError�sentry_sdk._typesr �typingr r r r r �rq.jobr r r, rD r[ rH r@ �<module>r� s �� &� &� &� &� &� &� ���� � � � � � � )� )� )� )� )� )� � � � � � � =� =� =� =� =� =� =� =� 9� 9� 9� 9� 9� 9� 6� 6� 6� 6� 6� 6�� � � � � � � � � � � �+� � � � � � �/�/�/�/�/�/�0�0�0�0�0�0� � � � � � � ��� +� +� +� �,�)� *� *�*�+���� ,� +� +� +� +� +�� �*�*�*�*�*�*�*�*�*�*�0�0�0�0�0�0�(�(�(�(�(�(�������S#� S#� S#� S#� S#�K� S#� S#� S#�l � � �>(� (� (� (� (s �A �A(