Q\ d dl mZ d dlZd dlmZ d dlmZ d dlmZ d dl m
Z
d dl m Z d dl
mZmZ d d lmZ d d
lmZmZ d d lmZmZmZmZ d dlZd d l m Z d d
l m Z d dlm!Z!m"Z"m#Z#m$Z$ n# e%$ r ed w xY wer0d dl&m'Z'm(Z(m)Z)m*Z* d dlm+Z+m,Z,m-Z-m.Z. d dl/m0Z0 d dl1m2Z2 d dl3m4Z4 d dlm5Z5 e!e"e#fZ6 G d de Z7d Z8d Z9d Z:d Z;d Zd Z?dS ) )absolute_importN)reraise)
TYPE_CHECKING)Hub)OP)_should_send_default_pii) DidNotEnable Integration)
ignore_logger) TransactionTRANSACTION_SOURCE_TASK)capture_internal_exceptionsevent_from_exceptionSENSITIVE_DATA_SUBSTITUTE
parse_version)VERSION)ArqRedis)JobExecutionFailedRetryRetryJobWorkerzArq is not installed)AnyDictOptionalUnion)EventProcessorEventExcInfoHint)CronJob)Job)WorkerCoroutine)Functionc ( e Zd ZdZed ZdS )ArqIntegrationarqc t t t rt t } nt j d d } n# t
t f$ r d } Y nw xY w| 't d t | dk rt d t t t t d d S )N zUnparsable arq version: {})r zarq 0.23 or newer required.z
arq.worker)
isinstance ARQ_VERSIONstrr version TypeError
ValueErrorr formatpatch_enqueue_job
patch_run_jobpatch_create_workerr )r- s m/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/sentry_sdk/integrations/arq.py
setup_oncezArqIntegration.setup_once, s +s++
2' 44%-bqb1:& GGG ? ; B B; O OPP P W <== = l#####s AA A A N)__name__
__module__ __qualname__
identifier staticmethodr5 r4 r% r% ) s2 J$ $ \$ $ $r< r% c B t j fd} | t _ d S )Nc K t j }| t | |g|R i | d {V S | t
j | 5 | |g|R i | d {V cd d d S # 1 swxY w Y d S )N)op description)r currentget_integrationr%
start_spanr QUEUE_SUBMIT_ARQ)selffunctionargskwargshubold_enqueue_jobs r4 _sentry_enqueue_jobz.patch_enqueue_job.._sentry_enqueue_jobJ s k ~ . . 6( xI$III&IIIIIIII I
^^r 2^
I
I J J( xI$III&IIIIIIII J J J J J J J J J J J J J J J J J Js A>>BB)r enqueue_job)rK rJ s @r4 r1 r1 F s9 *OJ J J J J /Hr< c B t j fd} | t _ d S )Nc K t t j }| t | || d {V S | 5 }d|_ | t ddt j t }| | 5 | || d {V cd d d cd d d S # 1 swxY w Y d d d d S # 1 swxY w Y d S )Nr& zunknown arq taskok)namestatusr? source) r rA rB r%
push_scope_nameclear_breadcrumbsr r QUEUE_TASK_ARQr
start_transaction)rE job_idscorerI scope transaction old_run_jobs r4 _sentry_run_jobz&patch_run_job.._sentry_run_job[ s #+ ~ . . 6$T6599999999 9
^^
> EK # # % % %%'$. K &&{33
>
> ([vu = =======
>
>
>
>
>
>
> > > > > > > > >
>
>
>
>
>
>
>
>
> > > > > > > > > > > > > > > > > > >s7 AC61C C6 C! !C6$C! %C66C:=C:)r run_job)r] r\ s @r4 r2 r2 W s0 .K> > > > >* %FNNNr< c l t j }|j j O| d t v r!|j j d d S |j j d t
| |j r |j j nd t j
dd \ }}| || d S )Nr abortedinternal_errorF)typehandled)client_options mechanism)hint) r rA rZ r[ ARQ_CONTROL_FLOW_EXCEPTIONS
set_statusr clientoptionsr% r9
capture_event)exc_inforI eventrf s r4 _capture_exceptionrn s s
+C
y ( A;5 5 5 I ! , ,Y 7 7 7 F (()9:::&-0ZAsz))T)4GG KE4
e$'''''r< c fd}|S )Nc t j }t 5 |j j "d |j j _ d | d< | di }d |d< d dk |d< | d i }d t rnt t rnt d d
|d < d d d n # 1 swxY w Y | S ) Njob_namer[ tagsrX arq_task_idjob_try arq_task_retryextra)taskrG rH retryzarq-job) r rA r rZ r[ rP
setdefaultr r )rm rf rI rr rw rG ctxrH s r4 event_processorz._make_event_processor..event_processor s3 k
(
*
* y$0-0_ %*'*:m$##FB//D"%h-D %(^a%7D! "$$Wb11EJ+--/.+--/&&. Y E) ( s B5C C!$C!r; )r{ rG rH r| s ``` r4 _make_event_processorr} s0 6 r< c fd}|S )Nc n K t j }| t |i | d {V S |j t
i | dig|R i | | g|R i | d {V }n;# t $ r. t j }t | t | Y nw xY w|S )Nrq ) r rA rB r% rZ add_event_processorr} Exceptionsysrl rn r )r{ rG rH rI resultrl coroutinerP s r4 _sentry_coroutinez*_wrap_coroutine.._sentry_coroutine s k ~ . . 6"D3F33333333 3 %% !";S";*d";"; Md M M Mf M M
$9S:4:::6::::::::FF |~~H x ( ( ( X
s 'A: :5B21B2r; )rP r r s `` r4 _wrap_coroutiner s* & r< c V t j j fd} | t j _ d S )Nc t j }| t | i |S | d }|j }|j }d |D |_ d |D |_ | i |S )Nr c , g | ]}t | S r; )_get_arq_function).0funcs r4
zFpatch_create_worker.._sentry_create_worker.. s! !P!P!Pd"3D"9"9!P!P!Pr< c , g | ]}t | S r; )_get_arq_cron_job)r cron_jobs r4 r zFpatch_create_worker.._sentry_create_worker.. s! !X!X!X("3H"="=!X!X!Xr< )r rA rB r% functions cron_jobs)rG rH rI settings_clsr r old_create_workers r4 _sentry_create_workerz2patch_create_worker.._sentry_create_worker s k ~ . . 6$$d5f55 5Aw * * !P!Pi!P!P!P !X!Xi!X!X!X $1&111r< )r& worker
create_worker)r r s @r4 r3 r3 s9
02 2 2 2 2" 5CJ r< c t j | }t |j |j |_ |S N)r& r r r rP r )r arq_funcs r4 r r s1 zt$$H( 8JKKH Or< c D t | j | j | _ | S r )r rP r )r s r4 r r s ( 8JKKH Or< )@
__future__r r sentry_sdk._compatr sentry_sdk._typesr
sentry_sdkr sentry_sdk.constsr sentry_sdk.hubr sentry_sdk.integrationsr r
sentry_sdk.integrations.loggingr sentry_sdk.tracingr r
sentry_sdk.utilsr r r r
arq.workerr& arq.versionr r+ arq.connectionsr r r r r ImportErrortypingr r r r r r r r arq.cronr arq.jobsr!
arq.typingr" r# rg r% r1 r2 rn r} r r3 r r r; r< r4 r s & & & & & &
& & & & & & + + + + + + 3 3 3 3 3 3 = = = = = = = = 9 9 9 9 9 9 C C C C C C C C /222222((((((FFFFFFFFFFFFF / / /
,-
.
../ $111111111111FFFFFFFFFFFF ******###### 15( C $ $ $ $ $[ $ $ $:/ / /"% % %8( ( (& @ 05 5 50 s A) )A: