kuޢAq d dl mZ d dlZd dlmZ d dlmZ d dlmZ d dlm Z d dl
m Z d dl m
Z
d d lmZmZ d d
lmZmZ d d lmZmZmZ er3d d lmZmZmZm Z m Z d d
lm Z m Z m Z d dlm!Z! e dedef Z" d dl#m$Z$m%Z%m&Z&m'Z' d dl(m)Z)m*Z*m+Z+ n# e,$ r ed w xY we)e*e+fZ- G d de Z.d Z/d Z0d Z1d Z2d Z3dS ) )absolute_importN)datetime)reraise)
TYPE_CHECKING)Hub)OP)_should_send_default_pii) DidNotEnable Integration) TransactionTRANSACTION_SOURCE_TASK)capture_internal_exceptionsevent_from_exceptionSENSITIVE_DATA_SUBSTITUTE)AnyCallableOptionalUnionTypeVar)EventProcessorEventHint)ExcInfoF.)bound)HueyResult ResultGroupTask)CancelExecution RetryTaskTaskLockedExceptionzHuey is not installedc ( e Zd ZdZed ZdS )HueyIntegrationhueyc > t t d S N)
patch_enqueue
patch_execute n/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/sentry_sdk/integrations/huey.py
setup_oncezHueyIntegration.setup_once( s r+ N)__name__
__module__ __qualname__
identifier staticmethodr- r* r+ r, r$ r$ % s2 J \ r+ r$ c B t j fd} | t _ d S )Nc t j }| t | | S | t
j |j 5 | | cd d d S # 1 swxY w Y d S )N)op description)r currentget_integrationr$
start_spanr QUEUE_SUBMIT_HUEYname)selftaskhub old_enqueues r, _sentry_enqueuez&patch_enqueue.._sentry_enqueue3 s k / / 7 ;tT** *
^^r 3^
K
K + + ;tT** + + + + + + + + + + + + + + + + + +s A33A7:A7)r enqueue)r@ r? s @r, r( r( / s0 ,K+ + + + + #DLLLr+ c fd}|S )Nc t 5 | di }j |d< j j k |d< | di }j t
rj nt t
rj nt j pdj z
d|d< d d d n # 1 swxY w Y | S )Ntags huey_task_idhuey_task_retryextrar )r= argskwargsretryzhuey-job)
r
setdefaultiddefault_retriesretriesr; r rH r rI )eventhintrD rG r= s r, event_processorz._make_event_processor..event_processorB s )
*
* ##FB//D#'7D &*&:T\&ID" #$$Wb11E +--/ .+--/$++. .3!t|C ! !E* s B B88B<?B<r* )r= rQ s ` r, _make_event_processorrR @ s$ * r+ c T t j }| 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)rP ) r r7 HUEY_CONTROL_FLOW_EXCEPTIONSscope transaction
set_statusr clientoptionsr$ r1
capture_event)exc_infor> rO rP s r, _capture_exceptionrb Z s
+C{222 ((333I$$%5666&-0ZAsz))T*5%HH KE4
e$'''''r+ c fd}|S )Nc t j }| t | i |S | i |}n;# t $ r. t j }t | t | Y nw xY w|S r' ) r r7 r8 r$ Exceptionsysra rb r )rH rI r> resultra funcs r, _sentry_executez+_wrap_task_execute.._sentry_executem s k / / 74((( ( T4*6**FF |~~H x ( ( ( X
s : 5A21A2r* )rh ri s ` r, _wrap_task_executerj k s$
r+ c D t j dfd } | t _ d S )Nc t j }| t
| || S | 5 }t 5 d|_ | | t | d d d n # 1 swxY w Y t |j dt j
t }t |dd s t! |j |_ d|_ | | 5 | || cd d d cd d d S # 1 swxY w Y d d d d S # 1 swxY w Y d S )Nr% ok)r; statusr5 source_sentry_is_patchedFT)r r7 r8 r$
push_scoper _nameclear_breadcrumbsadd_event_processorrR r r; r QUEUE_TASK_HUEYr
getattrrj executerp start_transaction)r< r= timestampr> r[ r\ old_executes r, ri z&patch_execute.._sentry_execute sI k / / 7 ;tT955 5
^^
:,..
G
G $ '')))))*?*E*EFFF
G
G
G
G
G
G
G
G
G
G
G
G
G
G
G
&Y%. K 4!5u==
/ 1$, ? ? *.'&&{33
:
:"{4y99
:
:
:
:
:
:
:# : : : : : : : :"
:
:
:
:
:
:
:
:
:# : : : : : : : : : : : : : : : : : :s[ E>B" E"B& &E)B& *A0E
E ' E E EE EE E r' )r _execute)ri rz s @r, r) r) s5 -K: : : : : :6 $DMMMr+ )4
__future__r rf r sentry_sdk._compatr sentry_sdk._typesr
sentry_sdkr sentry_sdk.constsr sentry_sdk.hubr sentry_sdk.integrationsr
r sentry_sdk.tracingr r
sentry_sdk.utilsr r r typingr r r r r r r r r r huey.apir r r r huey.exceptionsr r! r" ImportErrorrZ r$ r( rR rb rj r) r* r+ r, r st & & & & & &
& & & & & & + + + + + + 3 3 3 3 3 3 = = = = = = = = C C C C C C C C />>>>>>>>>>>>>>==========((((((8CH-...A0888888888888OOOOOOOOOOO 0 0 0
,.
/
//0 !0