← Back
Editing: 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"