bg#JddlmZddlZddlmZddlmZddlmZddl m Z m Z ddl m Z ddlmZdd lmZmZmZmZ dd lmZdd lmZdd lmZdd lmZn#e$r e dwxYwddlm Z e rddl!m"Z"m#Z#m$Z$ddlm%Z%ddlm&Z&ddl'm(Z(Gdde Z)dZ*dZ+dS))absolute_importN)OP)continue_trace)Hub) DidNotEnable Integration) ignore_logger)TRANSACTION_SOURCE_TASK)capture_internal_exceptionsevent_from_exceptionformat_timestamp parse_version)Queue)JobTimeoutException)VERSION)WorkerzRQ not installed) TYPE_CHECKING)AnyCallableDict)EventProcessor)ExcInfo)Jobc(eZdZdZedZdS) RqIntegrationrqc|tt}|'tdt|dkrtdtjfd}|t_tjfd}|t_tjfd}|t_tddS)NzUnparsable RQ version: {})rzRQ 0.6 or newer is required.ctj}|t}|  ||g|Ri|S|j}|J|5}||ttj |t|j dpitjdt }t#5|j|_dddn #1swxYwY||d|i5 ||g|Ri|} dddn #1swxYwYdddn #1swxYwY|jr|| S)N_sentry_trace_headerszunknown RQ task)opnamesourcerq_job)custom_sampling_context)rcurrentget_integrationrclient push_scopeclear_breadcrumbsadd_event_processor_make_event_processorweakrefrefrmetagetr QUEUE_TASK_RQr r func_namer"start_transactionis_horseflush) selfjobargskwargshub integrationr(scope transactionrvold_perform_jobs Q/opt/cloudlinux/venv/lib64/python3.11/site-packages/sentry_sdk/integrations/rq.pysentry_patched_perform_jobz.sentry_patched_perform_job6sv+C--m<.sentry_patched_handle_exception`s>} -"8,,,''cGHGGGGG Gctj}|t5|jj)t ||jd<||fi|S)Nr ) rr&r'rr<spandictiter_trace_propagation_headersr/)r6r7r9r:old_enqueue_jobs r@sentry_patched_enqueue_jobz.sentry_patched_enqueue_jobksj+C""=11=9>-8<::<<99CH45#?47777 7rHz rq.worker) r RQ_VERSIONrformatr perform_jobhandle_exceptionr enqueue_jobr )versionrArGrNrMrFr?s @@@r@ setup_oncezRqIntegration.setup_once(s ++ ?:AA*MMNN N V  =>> > ,$ $ $ $ $ L8%6 H H H H H#B+ 8 8 8 8 87k"""""rHN)__name__ __module__ __qualname__ identifier staticmethodrUrHr@rr%s7JO#O#\O#O#O#rHrcfd}|S)Nc }|t5|di}|j|j|j|j|jd|d<|jrt|j|dd<|j rt|j |dd<dddn #1swxYwYd|vrTt5t|ddtr dd |jg|d <dddn #1swxYwY|S) Nextra)job_idfuncr8r9 descriptionzrq-job enqueued_at started_atrErrr fingerprint) r setdefaultidr2r8r9rarbr rc issubclassr)eventhintr7r^weak_jobs r@event_processorz._make_event_processor..event_processor}shjj ?,.. U U(("55!fMH!j#&? ##h?W5Eco5V5VE(OM2>U4DS^4T4TE(OL1 U U U U U U U U U U U U U U U   ,.. X Xd:.q13FGGX,02G+WE-( X X X X X X X X X X X X X X X s$BB++B/2B//DD Dr[)rjrks` r@r,r,{s$4 rHc tj}|tdS|j}t ||jddd\}}|||dS)NrF)typehandled)client_options mechanism)ri)rr&r'rr(r options capture_event)rEr9r:r(rhris r@rDrDsw +C =))1ZF&~E22KE4 e$'''''rH), __future__rr-sentry_sdk.constsrsentry_sdk.apirsentry_sdk.hubrsentry_sdk.integrationsrrsentry_sdk.integrations.loggingr sentry_sdk.tracingr sentry_sdk.utilsr r r rrq.queuer rq.timeoutsr rq.versionrrO rq.workerr ImportErrorsentry_sdk._typesrtypingrrrrrrq.jobrrr,rDr[rHr@rs&&&&&& ))))))========999999666666+//////000000       +++ ,) * **+,+++++**********000000((((((S#S#S#S#S#KS#S#S#l>(((((s AA(