관리-도구
편집 파일: rq.cpython-311.pyc
� � ��� �. � d dl mZ d dlZd dlmZ d dlmZmZ d dlm Z d dl m Z m Z d dl mZ d dlmZ d d lmZ d d lmZ n# e$ r ed � � �w xY wd d lmZ er$d d lmZ d dlmZ d dlm Z d dl m Z d dl m Z d dlm Z G d� de� � Z!d� Z"d� Z#dS )� )�absolute_importN)�Hub)� Integration� DidNotEnable)� Transaction)�capture_internal_exceptions�event_from_exception)�VERSION)�JobTimeoutException)�Worker)�QueuezRQ not installed)�MYPY)�Any)�Dict)�Callable)�Job)�ExcInfo)�EventProcessorc �( � e Zd ZdZed� � � ZdS )� RqIntegration�rqc �� ���� t t t t j d� � d d� � � � � } n<# t t f$ r( t d� t � � � � �w xY w| dk rt d� � �t j ��fd�}|t _ t j ��fd�}|t _ t j ��fd�}|t _ d S ) N�.� zUnparsable 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 |j � d� � pi dd�� � }t � � 5 |j |_ d d d � � n # 1 swxY w Y |� |� � 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_headerszrq.taskzunknown RQ task)�op�name)r �current�get_integrationr �client� push_scope�clear_breadcrumbs�add_event_processor�_make_event_processor�weakref�refr �continue_from_headers�meta�getr � func_namer �start_transaction�is_horse�flush) �self�job�args�kwargs�hub� integrationr" �scope� transaction�rv�old_perform_jobs ��z/builddir/build/BUILD/imunify360-venv-2.5.2/opt/imunify360/venv/lib/python3.11/site-packages/sentry_sdk/integrations/rq.py�sentry_patched_perform_jobz<RqIntegration.setup_once.<locals>.sentry_patched_perform_job1 sa �� ��+�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� �*� � � � � 1�2�2� 5� 5�'*�}�K�$�5� 5� 5� 5� 5� 5� 5� 5� 5� 5� 5���� 5� 5� 5� 5� �*�*�;�7�7� 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� C7�+ E�7C; �;E�>C; �?E�D1�% E�1D5 �5E�8D5 �9E�E �E c �< �� t |� � �| |g|�R i |��S )N)�_capture_exception)r0 r1 �exc_infor3 �old_handle_exceptions �r: � sentry_patched_handle_exceptionzARqIntegration.setup_once.<locals>.sentry_patched_handle_exceptionX s4 �� � �x� (� (� (�'�'��c�G�H�G�G�G��G�G� G� c � �� t j }|� t � � �)t |� � � � � |j d< �| |fi |��S )Nr )r r r! r �dict� iter_trace_propagation_headersr* )r0 r1 r3 r4 �old_enqueue_jobs �r: �sentry_patched_enqueue_jobz<RqIntegration.setup_once.<locals>.sentry_patched_enqueue_joba s` �� ��+�C��"�"�=�1�1�=�48��6�6�8�8�5� 5���0�1� #�?�4��7�7��7�7� 7rA )�tuple�map�int� RQ_VERSION�split� ValueError� TypeErrorr �formatr � perform_job�handle_exceptionr � enqueue_job)�versionr; r@ rF rE r? r9 s @@@r: � setup_oncezRqIntegration.setup_once# s$ ���� � O��C��Z�%5�c�%:�%:�2�A�2�%>� ?� ?�@�@�G�G���I�&� O� O� O� � :� A� A�*� M� M�N�N� N� O���� �V� � � � =�>�>� >� �,��! � ! � ! � ! � ! �F 8��� %� 6� � H� H� H� H� H� #B�� � �+�� 8� 8� 8� 8� 8� 7����s �<A �9A;N)�__name__� __module__� __qualname__� identifier� staticmethodrS � rA r: r r s7 � � � � � ��J��G7� G7� �\�G7� G7� G7rA r c � � � � fd�}|S )Nc � �� �� � }|�`t � � 5 | � di � � }|j |j |j |j |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�funcr2 r3 � descriptionzrq-jobr> r r r � fingerprint) r � setdefault�idr, r2 r3 r_ � issubclassr )�event�hintr1 r\ �weak_jobs �r: �event_processorz._make_event_processor.<locals>.event_processorp sj �� ��h�j�j�� �?�,�.�.� � � �(�(��"�5�5�� !�f� �M� �H� !�j�#&�?� #� #��h�� � � � � � � � � � � ���� � � � � �� � �,�.�.� 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# �;A#�#A'�*A'� /B;�;B?�B?rY )rf rg s ` r: r& r& n s$ �� �� � � � �* �rA c �� � t j }|� t � � �d S |j }t | |j ddd��� � \ }}|� ||�� � d S )Nr F)�type�handled)�client_options� mechanism)re )r r r! r r" r �options� capture_event)r> r3 r4 r" rd re s r: r= r= � sw � � �+�C� ���=�)�)�1��� �Z�F�&�� �~� �E�2�2�� � �K�E�4� ���e�$��'�'�'�'�'rA )$� __future__r r' �sentry_sdk.hubr �sentry_sdk.integrationsr r �sentry_sdk.tracingr �sentry_sdk.utilsr r � rq.versionr rJ � rq.timeoutsr � rq.workerr �rq.queuer � ImportError�sentry_sdk._typesr �typingr r r �rq.jobr r r r r& r= rY rA r: �<module>r| s� �� &� &� &� &� &� &� ���� � � � � � � =� =� =� =� =� =� =� =� *� *� *� *� *� *� N� N� N� N� N� N� N� N�+�0�0�0�0�0�0�/�/�/�/�/�/� � � � � � � � � � � � � ��� +� +� +� �,�)� *� *�*�+���� #� "� "� "� "� "�� 1������������� � � � � � �������(�(�(�(�(�(�0�0�0�0�0�0�K7� K7� K7� K7� K7�K� K7� K7� K7�\� � �4(� (� (� (� (s �A �A