bg\ddlmZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z dd lmZmZdd lmZmZdd lmZmZmZer3dd lmZmZmZmZmZdd lmZmZm Z ddlm!Z!ededefZ" ddl#m$Z$m%Z%m&Z&m'Z'ddl(m)Z)m*Z*m+Z+n#e,$r edwxYwe)e*e+fZ-GddeZ.dZ/dZ0dZ1dZ2dZ3dS))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(eZdZdZedZdS)HueyIntegrationhueyc>ttdSN) patch_enqueue patch_executem/builddir/build/BUILD/cloudlinux-venv-1.0.7/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$%s2J\r+r$cBtjfd}|t_dS)Nctj}|t ||S|t j|j5||cdddS#1swxYwYdS)N)op description)rcurrentget_integrationr$ start_spanrQUEUE_SUBMIT_HUEYname)selftaskhub old_enqueues r,_sentry_enqueuez&patch_enqueue.._sentry_enqueue3sk    / / 7;tT** * ^^r3^ K K + +;tT** + + + + + + + + + + + + + + + + + +s A33A7:A7)renqueue)r@r?s @r,r(r(/s0,K+++++#DLLLr+cfd}|S)Nct5|di}j|d<jjk|d<|di}jt rjntt rj ntjpdjz d|d<dddn #1swxYwY|S)Ntags huey_task_idhuey_task_retryextrar)r=argskwargsretryzhuey-job) r setdefaultiddefault_retriesretriesr;r rHrrI)eventhintrDrGr=s r,event_processorz._make_event_processor..event_processorBs) * *  ##FB//D#'7D &*&:T\&ID" #$$Wb11E +--/ .+--/$++..3!t|C ! !E*                   sBB88B<?B<r*)r=rQs` r,_make_event_processorrR@s$* r+cTtj}|dtvr!|jjddS|jjdt ||jr |jjndtj dd\}}| ||dS)Nrabortedinternal_errorF)typehandled)client_options mechanism)rP) rr7HUEY_CONTROL_FLOW_EXCEPTIONSscope transaction set_statusrclientoptionsr$r1 capture_event)exc_infor>rOrPs r,_capture_exceptionrbZs +C{222 ((333I$$%5666&-0ZAsz))T*5%HHKE4 e$'''''r+cfd}|S)Nctj}|t|i|S |i|}n;#t$r.t j}t|t|YnwxYw|Sr') rr7r8r$ Exceptionsysrarbr)rHrIr>resultrafuncs r,_sentry_executez+_wrap_task_execute.._sentry_executemsk    / / 74((( ( T4*6**FF   |~~H x ( ( ( X       s:5A21A2r*)rhris` r,_wrap_task_executerjks$      r+cDtjdfd }|t_dS)Nctj}|t |||S|5}t 5d|_||t|dddn #1swxYwYt|j dtj t}t|dds t!|j|_d|_||5|||cdddcdddS#1swxYwY ddddS#1swxYwYdS)Nr%ok)r;statusr5source_sentry_is_patchedFT)rr7r8r$ push_scoper_nameclear_breadcrumbsadd_event_processorrRr r;rQUEUE_TASK_HUEYr getattrrjexecuterpstart_transaction)r<r= timestampr>r[r\ old_executes r,riz&patch_execute.._sentry_executesIk    / / 7;tT955 5 ^^   :,.. G G$ '')))))*?*E*EFFF G G G G G G G G G G G G G G G &Y%. K4!5u== /1$,?? *.'&&{33 : :"{4y99 : : : : : : :# : : : : : : : :" : : : : : : : : :# : : : : : : : : : : : : : : : : : :s[ E>B" E"B& &E)B& *A0E E' EE EE EE Er')r_execute)rirzs @r,r)r)s5-K::::::6$DMMMr+)4 __future__rrfrsentry_sdk._compatrsentry_sdk._typesr sentry_sdkrsentry_sdk.constsrsentry_sdk.hubr sentry_sdk.integrationsr r sentry_sdk.tracingr r sentry_sdk.utilsrrrtypingrrrrrrrrrrhuey.apirrrrhuey.exceptionsr r!r" ImportErrorrZr$r(rRrbrjr)r*r+r,rst&&&&&& &&&&&&++++++ 333333========CCCCCCCC />>>>>>>>>>>>>>==========((((((8CH-...A0888888888888OOOOOOOOOOO000 ,. / //0!0