ZQC 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_exceptionsevent_from_exceptionformat_timestamp
parse_version)Queue)JobTimeoutException)VERSION)WorkerzRQ not installed)
TYPE_CHECKING)AnyCallableDict)EventProcessor)ExcInfo)Jobc ( e Zd ZdZed ZdS )
RqIntegrationrqc | 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)opnamesourcerq_job)custom_sampling_context)r currentget_integrationr client
push_scopeclear_breadcrumbsadd_event_processor_make_event_processorweakrefrefr metagetr
QUEUE_TASK_RQr
r func_namer" start_transactionis_horseflush) selfjobargskwargshub integrationr( scope transactionrvold_perform_jobs l/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/sentry_sdk/integrations/rq.pysentry_patched_perform_jobz.sentry_patched_perform_job6 sv +C --m<.sentry_patched_handle_exception` s> }
-"8,,,''cGHGGGGG G c t j }| t 5|j j )t
| |j d< | |fi |S )Nr ) r r& r' r r< spandict iter_trace_propagation_headersr/ )r6 r7 r9 r: old_enqueue_jobs r@ sentry_patched_enqueue_jobz.sentry_patched_enqueue_jobk sj +C""=11=9>-8<::<<9 9CH 45 #?47777 7rH z rq.worker)
r
RQ_VERSIONr formatr perform_jobhandle_exceptionr enqueue_jobr )versionrA rG rN rM rF r? s @@@r@
setup_oncezRqIntegration.setup_once( s
++ ? : A A* M MNN N V =>> > ,$ $ $ $ $ L 8 % 6 H H H H H #B + 8 8 8 8 8 7k"""""rH N)__name__
__module__ __qualname__
identifier staticmethodrU rH r@ r r % s7 JO# 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 ) Nextra)job_idfuncr8 r9 descriptionzrq-job enqueued_at
started_atrE r r r fingerprint) r
setdefaultidr2 r8 r9 ra rb r
rc
issubclassr )eventhintr7 r^ weak_jobs r@ event_processorz._make_event_processor..event_processor} s hjj ?,..
U
U (("55 !f M H !j#&? # #h ? W5Eco5V5VE(OM2> U4DS^4T4TE(OL1
U
U
U
U
U
U
U
U
U
U
U
U
U
U
U ,..
X
X d: .q 13FGG X,02G +WE-(
X
X
X
X
X
X
X
X
X
X
X
X
X
X
X s$ BB++B/2B//DD
Dr[ )rj rk s ` r@ r, r, { s$ 4 rH c t j }| t d S |j }t | |j ddd \ }}| || d S )Nr F)typehandled)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 ZF& ~ E22 KE4 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 ImportErrorsentry_sdk._typesr typingr r r r r rq.jobr r r, rD r[ rH r@ r s & & & & & & ) ) ) ) ) ) = = = = = = = = 9 9 9 9 9 9 6 6 6 6 6 6 + //////000000 + + +
,)
*
**+ , + + + + + **********000000((((((S# S# S# S# S#K S# S# S#l >( ( ( ( (s A A(