. 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_exceptionsevent_from_exception)VERSION)JobTimeoutException)Worker)QueuezRQ not installed)MYPY)Any)Dict)Callable)Job)ExcInfo)EventProcessorc ( e Zd ZdZed ZdS )
RqIntegrationrqc 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)opname)r currentget_integrationr client
push_scopeclear_breadcrumbsadd_event_processor_make_event_processorweakrefrefr continue_from_headersmetagetr func_namer start_transactionis_horseflush) selfjobargskwargshub integrationr" scope transactionrvold_perform_jobs z/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/sentry_sdk/integrations/rq.pysentry_patched_perform_jobz.sentry_patched_perform_job1 sa +C --m<C; ?ED1% E1D5 5E8D5 9EE E c < t | | |g|R i |S )N)_capture_exception)r0 r1 exc_infor3 old_handle_exceptions r: sentry_patched_handle_exceptionzARqIntegration.setup_once..sentry_patched_handle_exceptionX s4 x ( ( (''cGHGGGGG 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.sentry_patched_enqueue_joba s` +C""=11=4866885 501 #?47777 7rA )tuplemapint
RQ_VERSIONsplit
ValueError TypeErrorr formatr perform_jobhandle_exceptionr
enqueue_job)versionr; r@ rF rE r? r9 s @@@r:
setup_oncezRqIntegration.setup_once# s$ OCZ%5c%:%:2A2%> ? ?@@GGI& O O O : A A* M MNN N O V =>> > ,! ! ! ! ! F 8 % 6 H H H H H
#B + 8 8 8 8 8 7s r r r fingerprint) r
setdefaultidr, r2 r3 r_
issubclassr )eventhintr1 r\ weak_jobs r: event_processorz._make_event_processor..event_processorp sj hjj ?,..
(("55 !f M H !j#&? # #h
,..
X
X d: .q 13FGG X,02G +WE-(
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)typehandled)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 ZF& ~ E22 KE4 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
ImportErrorsentry_sdk._typesr typingr r r rq.jobr r r r r& r= rY rA r: r| s & & & & & & = = = = = = = = * * * * * * N N N N N N N N+000000////// + + +
,)
*
**+ # " " " " " 1 ((((((000000K7 K7 K7 K7 K7K K7 K7 K7\ 4( ( ( ( (s A A