+ޜ]3 d dl mZ d dlZd dlmZ d dlmZmZ d dlm Z d dl
m Z d dl m
Z
mZ d dlmZ d d lmZ d d
lmZ er9d d lmZ d d lmZ d d
lmZ d dlmZ d dlmZmZm Z m Z ededef Z d dl m Z! d dl"m#Z#m$Z$m%Z%m&Z& n# e'$ r ed w xY we$e%e&fZ( G d de
Z)d Z*d Z+d Z,d dZ-d Z.d Z/d Z0dS ) )absolute_importN)Hub)capture_internal_exceptionsevent_from_exception) Transaction)reraise) Integration DidNotEnable)
ignore_logger)MYPYwraps)Any)TypeVar)Callable)Optional)EventProcessorEventHintExcInfoF.)bound)VERSION)SoftTimeLimitExceededRetryIgnoreRejectzCelery not installedc 0 e Zd ZdZddZed ZdS )CeleryIntegrationceleryTc || _ d S N)propagate_traces)selfr# s ~/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/sentry_sdk/integrations/celery.py__init__zCeleryIntegration.__init__+ s 0 c ( t dk rt d dd lmc m} | j fd}|| _ ddlm} t |j |_ t t d t d t d d S ) N) zCelery 3 or newer required.r c t |dd s;t ||j |_ t ||j |_ d|_ t | | |g|R i | S )N_sentry_is_patchedFT)getattr_wrap_task_call__call__runr+ _wrap_tracer)nametaskargskwargsold_build_tracers r% sentry_build_tracerz9CeleryIntegration.setup_once..sentry_build_tracer9 sx 4!5u==
/ !0dm D D
*4::
+/' &6&6tT&SD&S&S&SF&S&STT Tr' )Taskzcelery.worker.jobzcelery.app.tracezcelery.redirected) CELERY_VERSIONr
celery.app.traceapptrace build_tracercelery.app.taskr7 _wrap_apply_async apply_async_patch_worker_exitr )r; r6 r7 r5 s @r%
setup_oncez CeleryIntegration.setup_once/ s D <== =((((((((( -
U
U
U
U
U 1((((((,T-=>>
)***())) )*****r' N)T)__name__
__module__ __qualname__
identifierr& staticmethodrA r' r% r r ( sH J1 1 1 1 (+ (+ \(+ (+ (+r' r c < t fd }|S )Nc @ t j }| t }||j r| d| d j 5 t 5 t | }|rZ|
d pi }| | | di | ||d< d d d n # 1 swxY w Y | i |cd d d S # 1 swxY w Y d S | i |S )Nz
celery.submitr )op descriptionheaders)
r currentget_integrationr r#
start_spanr1 r dict iter_trace_propagation_headersgetupdate
setdefault)r3 r4 hub integrationrL
kwarg_headersfs r% r? z&_wrap_apply_async..apply_async] s k))*;<< "{'C " ?Q MM
*
*022 : : "3#E#E#G#G H HG : )/
9(=(=(C
%,,W555 &00B??FFwOOO,9y) : : : : : : : : : : : : : : :" q$)&))%
*
*
*
*
*
*
*
*
*
*
*
*
*
*
*
*
*
*( 1d%f%% %s7 D "A>C, D ,C0 0D 3C0 4
D DDr
)rX r? s ` r% r> r> [ s4
1XX& & & & X&6 r' c @ t fd }|S )Nc t j }| t | i |S | 5 }d|_ | | t g| R i | d }t 5 t j | d d pi dd }j
|_
| d d d d n # 1 swxY w Y | | i |cd d d S | | 5 | i |cd d d cd d d S # 1 swxY w Y d d d d S # 1 swxY w Y d S )Nr r) rL z celery.taskzunknown celery task)rJ r1 ok)r rM rN r
push_scope_nameclear_breadcrumbsadd_event_processor_make_event_processorr r continue_from_headersrR r1
set_statusstart_transaction)r3 r4 rU scope transactionrX r2 s r% _innerz _wrap_tracer.._inner s k 0 1 1 91d%f%% %
^^
*"EK # # % % % % %&;D&R4&R&R&R6&R&R S S S K -..
-
- ) ?GKK **0b$. $(9 &&t,,,
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- "q$)&))) * * * * * * * *, &&{33
*
*q$)&))
*
*
*
*
*
*
*- * * * * * * * *,
*
*
*
*
*
*
*
*
*- * * * * * * * * * * * * * * * * * *sb AE#AC3' E#3C7 7E#:C7 ; E#E#)E
1 E#
E E#E E##E'*E'r
r2 rX rf s `` r% r0 r0 | s; 1XX * * * * * X *> Mr' c @ t fd }|S )Nc | i |S # t $ rV t j }t 5 t | d d d n # 1 swxY w Y t | Y d S w xY wr" ) Exceptionsysexc_infor _capture_exceptionr )r3 r4 rl rX r2 s r% rf z _wrap_task_call.._inner s 1d%f%% % |~~H,..
3
3"4222
3
3
3
3
3
3
3
3
3
3
3
3
3
3
3 X s2 +A+A A+A A+A A+*A+r
rg s `` r% r- r- s; 1XX X Mr' c fd}|S )Nc t 5 | di }|d< | di }j d|d< d d d n # 1 swxY w Y d|v r^t 5 t |d d t rdd t d
g| d < d d d n # 1 swxY w Y | S ) Ntagscelery_task_idextra) task_namer3 r4 z
celery-jobrl r r r r1 fingerprint)r rT r1
issubclassr r, )eventhintrp rr r3 r4 r2 uuids r% event_processorz._make_event_processor..event_processor sj )
*
* ##FB//D%)D! "$$Wb11E !Y # #E, ,..
d: .q 13HII / fd33,E-(
s$ A A A #A 99B>>CCrG )r2 rx r3 r4 requestry s ```` r% r` r` s6 0 r' c t j }| t d S t |d t
rt
|d d S t
|d t | d r t |d | j rd S |j }t ||j ddd \ }}| || d S )
N abortedinternal_errorthrowsr F)typehandled)client_options mechanism)rw )
r rM rN r
isinstance CELERY_CONTROL_FLOW_EXCEPTIONS _set_statushasattrr clientr options
capture_event)r2 rl rU r rv rw s r% rm rm s
+C
,--5(1+ =>> C###%&&&tX :hqk4;#G#G ZF& ~#66 KE4 e$'''''r' c t 5 | 5 }|j |j | d d d n # 1 swxY w Y d d d d S # 1 swxY w Y d S r" )r configure_scopespanrb )rU statusrd s r% r r s $ & & . .
"
" .ez%
%%f--- . . . . . . . . . . . . . . .. . . . . . . . . . . . . . . . . .s4 A*"A A*A A*A A**A.1A.c : ddl m} | j fd}|| _ d S )Nr )Workerc | i |t 5 t j }| t | d d d S # 1 swxY w Y S # t 5 t j }| t | d d d w # 1 swxY w Y w xY wr" )r r rM rN r flush)r3 r4 rU old_workloops r% sentry_workloopz+_patch_worker_exit..sentry_workloop s< <000,..
k&&'899EIIKKK
,..
k&&'899EIIKKK
s@ A+ ;A A# &A# +C
:;C5 C
C C
C C
)
billiard.poolr workloop)r r r s @r% r@ r@ sD
%$$$$$?L &FOOOr' r" )1
__future__r rk sentry_sdk.hubr sentry_sdk.utilsr r sentry_sdk.tracingr sentry_sdk._compatr sentry_sdk.integrationsr r
sentry_sdk.integrations.loggingr sentry_sdk._typesr sentry_sdk._functoolsr typingr r r r r r r r r r r r8 celery.exceptionsr r r r ImportErrorr r r> r0 r- r` rm r r@ rG r' r% r s & & & & & &
N N N N N N N N * * * * * * & & & & & & = = = = = = = = 9 9 9 9 9 9 " " " " " " ' ' ' ' ' ' / FFFFFFFFFFFF8CH-...A /000000 / / /
,-
.
../ #(!8 0+ 0+ 0+ 0+ 0+ 0+ 0+ 0+f B) ) )X . :( ( (8. . .& & & & &s ;B B