\q d dl mZ d dlZd dlZd dlmZ d dlmZ d dlm Z d dl
m Z d dl m
Z
mZ d dlmZ d d lmZmZ d d
lmZ d d lmZmZ d d lmZ d d
lm Z m Z m Z m Z erQd dl m!Z! d dl m"Z" d dl m#Z# d dl m$Z$ d dl m%Z% d dl m&Z& d dl m'Z' d dl m(Z( d dlm)Z)m*Z*m+Z+m,Z, e'de"de!f Z- d dl.m/Z0 d dl.m1Z1m2Z2 d d l3m4Z4 d d l5m6Z6 d d l7m8Z8m9Z9m:Z:m;Z; d d lZ> d d l?m@Z@mAZAmBZB n# eC$ r ed! w xY we:e8e9fZD G d" d#e ZEd$ ZFd% ZGd& ZHd' ZId4d(ZJd) ZKd* ZLd+ ZMd, ZNd- ZOd. ZPd/ ZQd0 ZRd1 ZSd2 ZTd3 ZUdS )5 )absolute_importN)continue_trace)OP)reraisewraps)capture_checkin
MonitorStatus)Hub) Integration DidNotEnable)
ignore_logger)BAGGAGE_HEADER_NAMETRANSACTION_SOURCE_TASK)
TYPE_CHECKING)capture_internal_exceptionsevent_from_exceptionloggermatch_regex_list)Any)Callable)Dict)List)Optional)Tuple)TypeVar)Union)EventProcessorEventHintExcInfoF.)bound)VERSION)TaskCelery)task_has_custom) Scheduler)IgnoreRejectRetrySoftTimeLimitExceeded)crontabschedule) task_failure task_success
task_retryzCelery not installedc 6 e Zd ZdZ ddZed ZdS )CeleryIntegrationceleryTFNc p || _ || _ || _ |r t t d S d S N)propagate_tracesmonitor_beat_tasksexclude_beat_tasks_patch_beat_apply_entry_setup_celery_beat_signals)selfr7 r8 r9 s p/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/sentry_sdk/integrations/celery.py__init__zCeleryIntegration.__init__A sL !1 "4 "4 ) # % % % & ( ( ( ( ( ) ) 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 sft |d r5t |t | j t | _ nt ||j |_ d|_ t | | |g|R i | S )N_sentry_is_patchedF__call__T)getattrr' _wrap_task_calltyperD runrC _wrap_tracer)nametaskargskwargsold_build_tracers r= sentry_build_tracerz9CeleryIntegration.setup_once..sentry_build_tracerZ s 4!5u==
/ #444 ?*9$T
@S*T*TDJJ'' .tTX > >DH
+/' &6&6tT&SD&S&S&SF&S&STT Tr? )r% zcelery.worker.jobzcelery.app.tracezcelery.redirected) CELERY_VERSIONr
celery.app.traceapptrace build_tracercelery.app.taskr% _wrap_apply_async apply_async_patch_worker_exitr )rS rO r% rN s @r=
setup_oncez CeleryIntegration.setup_onceP s D <== =((((((((( - U U U U U" 1((((((,T-=>>
)***())) )*****r? )TFN)__name__
__module__ __qualname__
identifierr> staticmethodrY r? r= r3 r3 > sS J
)
)
)
) *+ *+ \*+ *+ *+r? r3 c ( t j S r6 )timer_ r? r= _now_seconds_since_epochrb ~ s 9;;r? c < t fd }|S )Nc
t j }| t }||j r| t j | d j 5 }t 5 t | | }|j r&|
ddt z i |r| d pi }| t }| t }|p|} |r|rd || } |
| | r
| |t < | di
| | r| |d t < | D ]%\ }
} |
d r | |d |
< &||d< d d d n # 1 swxY w Y | i |cd d d S # 1 swxY w Y d S | i |S )Nr )op description sentry-monitor-start-timestamp-sz%.9fheadersz{},{}zsentry-)r currentget_integrationr3 r7
start_spanr QUEUE_SUBMIT_CELERYrJ r dict iter_trace_propagation_headersr8 updaterb getr format
setdefaultitems
startswith)
rL rM hub integrationspanrh
kwarg_headersexisting_baggagesentry_baggagecombined_baggagekeyvaluefs
r= rW z&_wrap_apply_async..apply_async s k))*;<< "{'C " )tAw| 3
*022 .: .: "3#E#Ed#K#K L LG"5 BF":"<"<E= $: )/
9(=(=(C
+8+<+<=P+Q+Q()05H)I)I+9+M=M() .> /6~~ 0 .0 0 ,
&,,W555+ RAQM*= > &00B??FFwOOO+ 1 !1 *) 4 3 +8*=*=*?*? F FJC "~~i 8 8 F@E
i 8 =,9y)].: .: .: .: .: .: .: .: .: .: .: .: .: .: .:` q$)&))g3
* 3
* 3
* 3
* 3
* 3
* 3
* 3
* 3
* 3
* 3
* 3
* 3
* 3
* 3
* 3
* 3
* 3
*j 1d%f%% %s7 G0.EG G0G G0G
G00G47G4r )r~ rW s ` r= rV rV s5
1XX:& :& :& :& X:&x r? c @ t fd }|S )Nc
B t j }| t | i |S | 5 }d|_ | | t g| R i | d }t 5 t | d d pi t j
dt }j |_ | d d d d n # 1 swxY w Y | | i |cd d d S | |dj t% | d | d d
i 5 | i |cd d d cd d d S # 1 swxY w Y d d d d S # 1 swxY w Y d S ) Nr4 rA rh zunknown celery task)re rJ sourceok
celery_job )rK rL rM )custom_sampling_context)r ri rj r3
push_scope_nameclear_breadcrumbsadd_event_processor_make_event_processorr r rp r QUEUE_TASK_CELERYr rJ
set_statusstart_transactionlist)rL rM ru scope transactionr~ rK 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+.2 $(9 &&t,,,
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- "q$)&)))" * " * " * " * " * " * " * " *, && $ !%T!W
"&q' # #) '
*
* q$)&))
*
*
*
*
*
*
*-" * " * " * " * " * " * " * " *,
*
*
*
*
*
*
*
*
*-" * " * " * " * " * " * " * " * " * " * " * " * " * " * " * " * " * " *sb AFA C>2 F>D FD F ;FE;" F;E? ?FE? FFFr rK r~ r s `` r= rI rI s< 1XX(* (* (* (* (* X(*T 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 wr6 ) Exceptionsysexc_infor _capture_exceptionr )rL rM r r~ rK s r= r 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 r s `` r= rF rF 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_namerL rM z
celery-jobr r r4 r, rJ fingerprint)r rr rJ
issubclassr, rE )eventhintr r rL rM rK 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>>CCr_ )rK r rL rM requestr 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 )
Nr abortedinternal_errorthrowsr4 F)rG handled)client_options mechanism)r )
r ri rj r3
isinstance CELERY_CONTROL_FLOW_EXCEPTIONS _set_statushasattrr clientr options
capture_event)rK r ru r r r s r= r r 5 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 r6 )r configure_scoperw r )ru statusr s r= r r Q 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 wr6 )r r ri rj r3 flush)rL rM ru old_workloops r= sentry_workloopz+_patch_worker_exit..sentry_workloopb 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= rX rX Y sD
%$$$$$?L &FOOOr? c | j d pi }d|v r | |d |d= | | j d pi |S )Nrh
properties)r rp ro )rK rh s r= _get_headersr o st l y))/RG Gwy)*** I NN4<##L117R888 Nr? c d}t | } |D ]#\ }}| |k rt | |z }||fc S $t | dfS )N))dayg @)hourg @)minuteg N@second)floatint)seconds
TIME_UNITSunitdividerintervals r= _get_humanized_intervalr } so J GnnG# $ $
g g 7W,--H d# # # #
LL( ##r? c i }d }d }d }t | t rd}d | }nqt | t r8d}t | j \ }}|dk rt
j d|| i S n$t
j dt | i S i |d< ||d d< ||d d < | ||d d
< |j j
pd |d < |S )
Nr- zd{0._orig_minute} {0._orig_hour} {0._orig_day_of_month} {0._orig_month_of_year} {0._orig_day_of_week}r r zIntervals shorter than one minute are not supported by Sentry Crons. Monitor '%s' has an interval of %s seconds. Use the `exclude_beat_tasks` option in the celery integration to exclude it.z8Celery schedule type '%s' not supported by Sentry Crons.r. rG r} r UTCtimezone) r r- rq r. r r r warningrG confr )celery_schedulerR monitor_namemonitor_config
schedule_typeschedule_value
schedule_units r= _get_monitor_configr s6 NMNM/7++ !
$ %+F?$;$;
OX . . "
*A #+
+
' H $ $ N P
I
% F ! !
!#N: )6N: v&*8N: w' -:z"6*!$!2!;eN: r? c B t j fd} | t _ d S )Nc | \ }}|j }|j }|j }t j }| t }| | i |S t ||j r | i |S | 5 } |
t ||| }
t |
} | rp|j
di } | ||
d t! ||
t" j }
| d|
i | |j
d< | i |cd d d S # 1 swxY w Y d S )Nrh )sentry-monitor-slugsentry-monitor-config) monitor_slugr r sentry-monitor-check-in-id)rR r. rJ r ri rj r3 r r9 r set_new_propagation_contextr boolr popro r r
IN_PROGRESS)rL rM schedulerschedule_entryrR r r ru rv r r is_supported_schedulerh check_in_idoriginal_apply_entrys r= sentry_apply_entryz3_patch_beat_apply_entry..sentry_apply_entry s $(! >m(1%* k))*;<< ''888 8 L+*H I I 9''888 8
"
" 9e - - / / / 0 #| T TN$( $8$8 !$
<(044YCC/;1? .!-#1(4
+,,,+,,,'(((((r? c " t j d| t | }d|vrd S | di }t |d }t |d ||d t
|z
t j d S )Nzcelery_task_success %sr r rg r r r r durationr ) r debugr rp r r rb r
OKsenderrM rh r start_timestamp_ss r= r r s
L)62226""G G++ [[!8"==N g&H IJJ 23% 89)++.?? r? c " t j d| t | }d|vrd S | di }t |d }t |d ||d t
|z
t j d S )Nzcelery_task_failure %sr r rg r r r r r rp r r rb r
ERRORr s r= r r s
L)62226""G G++ [[!8"==N g&H IJJ 23% 89)++.?? " r? c " t j d| t | }d|vrd S | di }t |d }t |d ||d t
|z
t j d S )Nzcelery_task_retry %sr r rg r r r r s r= r r $ s
L'0006""G G++ [[!8"==N g&H IJJ 23% 89)++.?? " r? r6 )V
__future__r r ra sentry_sdk.apir sentry_sdk.constsr sentry_sdk._compatr sentry_sdk._functoolsr sentry_sdk.cronsr r
sentry_sdk.hubr sentry_sdk.integrationsr r
sentry_sdk.integrations.loggingr sentry_sdk.tracingr r sentry_sdk._typesr sentry_sdk.utilsr r r r typingr r r r r r r r r r r r! r" r4 r$ rP r% r& rQ r' celery.beatr( celery.exceptionsr) r* r+ r, celery.schedulesr- r. celery.signalsr/ r0 r1 ImportErrorr r3 rb rV rI rF r r r rX r r r r: r; r r r r_ r? r= r sQ & & & & & &
) ) ) ) ) ) & & & & & & ' ' ' ' ' ' ; ; ; ; ; ; ; ; = = = = = = = = 9 9 9 9 9 9 K K K K K K K K + + + + + + / FFFFFFFFFFFF8CH-...A/000000########000000%%%%%% 32222222
/ / /
,-
.
../ #(!8 =+ =+ =+ =+ =+ =+ =+ =+@ ? ? ?D4 4 4n . :( ( (8. . .& & &, $ $ $". . .b1/ 1/ 1/h) ) ) * * s 18C* *C;