Viewing File: /opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/__pycache__/rq.cpython-312.pyc
�
_�*j: � � � d dl Z d dlZd dlZd dlmZ d dlmZmZ d dlm Z m
Z
mZ d dlm
Z
d dlmZmZ d dlmZ d dlmZ d d lmZ d d
lmZmZmZmZmZ d dlmZ d dlm Z d d
l!m"Z" d dl#m$Z% d dl&m'Z' d dl&m)Z) e*e)d� sdZ)d dl+m,Z, e,rd dl+m-Z-m.Z. d dlm/Z/ d dl0m1Z1m2Z2 d dlm3Z3 G d� de
� Z4dd�Z5dd�Z6y# e($ r e d� �w xY w# e($ r dZ)Y �Rw xY w)� N)�continue_trace)�OP�SPANDATA)�DidNotEnable�Integration�_check_minimum_version)�
ignore_logger)�Scope�should_send_default_pii)�
SegmentSource)�TransactionSource)�has_span_streaming_enabled)�SENSITIVE_DATA_SUBSTITUTE�capture_internal_exceptions�event_from_exception�format_timestamp�
parse_version)� JobStatus)�Queue)�JobTimeoutException)�VERSION)�WorkerzRQ not installed)�
BaseWorker�perform_job)�
TYPE_CHECKING)�Any�Callable)�Job)�Event�EventProcessor)�ExcInfoc �, � e Zd ZdZde� �Zedd�� Zy)�
RqIntegration�rqzauto.queue.Nc �� ���� t t � } t t | � t �t nt
}|j �t j �� dddddddddt f
�fd �� }||_ |j � d
�fd
�}||_
t j �t j �� d�fd�� }|t _ t d� y )N�selfr �jobr �argsr �kwargs�returnc � �� t j � }|j t � �
�
| |g|��i |��S t j � 5 }|j � |j
t t j |� � � t |j � �rt j j |j j d� xs i � t! j"