JFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3RbrJFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3Rbr 0i>ddlZddlZddlmZddlmZddlmZmZm Z ddl m Z ddl m Z ddlmZmZmZmZmZ ddlmZdd lmZdd lmZdd lmZdd lmZddl m!Z!e!rddl m"Z"m#Z#ddl$m%Z%m&Z&ddlm'Z'ddlm(Z(Gdde Z)dZ*dZ+y#e$r ed wxYw)N)OP)continue_trace)_check_minimum_version DidNotEnable Integration) ignore_logger)TransactionSource)capture_internal_exceptionsensure_integration_enabledevent_from_exceptionformat_timestamp parse_version)Queue)JobTimeoutException)VERSION)Worker) JobStatuszRQ not installed) TYPE_CHECKING)AnyCallable)EventEventProcessor)ExcInfo)Jobc*eZdZdZdeZedZy) RqIntegrationrqz auto.queue.cjtt}tt|tj t tfd}|t_tjfd}|t_tjt tfd}|t_ tdy)Nctj5}|j|jt t j |t|jjdxsitjdtjtj}t!5|j"|_dddtj&|d|i5||g|i|}dddddd|j(r"tj*j-S#1swYpxYw#1swYMxYw#1swYQxYw)N_sentry_trace_headerszunknown RQ task)opnamesourceoriginrq_job)custom_sampling_context) sentry_sdk new_scopeclear_breadcrumbsadd_event_processor_make_event_processorweakrefrefrmetagetr QUEUE_TASK_RQr TASKrr$r func_namer"start_transactionis_horse get_clientflush)selfjobargskwargsscope transactionrvold_perform_jobs I/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/rq.pysentry_patched_perform_jobz.sentry_patched_perform_job1s%%'5'')))*? C@P*QR,HHLL!89?R''*,11(//  12'*}}K$3 11-5sO)sDTDVDB (*}}%%'--/I32('s<BE5D6!E(E6E6D? ;EE EEct|dxr|jxr|jdkD}|jtjk(xs |j }|r |s t |||g|i|S)N retries_leftr)hasattrrB_statusrFAILED is_failed_capture_exception)r7r8exc_infor:retryfailedold_handle_exceptions r?sentry_patched_handle_exceptionzARqIntegration.setup_once..sentry_patched_handle_exceptionUsx^,)$$)$$q(  [[I$4$44E Fe"8,'cGHGG Gctj}|j&t|j |j d<||fi|S)Nr )r'get_current_scopespandictiter_trace_propagation_headersr.)r7r8r:r;old_enqueue_jobs r?sentry_patched_enqueue_jobz.sentry_patched_enqueue_jobfsQ002Ezz%4888:501#477 7rMz rq.worker) r RQ_VERSIONrrr perform_jobr handle_exceptionr enqueue_jobr)versionr@rLrTrSrKr>s @@@r? setup_oncezRqIntegration.setup_once)s +}g6 ,, #M? C  D >8%66 H#B++ #M? C 8 D 87k"rMN)__name__ __module__ __qualname__ identifierr$ staticmethodrZrMr?rr%s'J:, 'FI#I#rMrcfd}|S)Nc&}|t5|jdi}|j|j|j|j |j d}|jrt|j|d<|jrt|j|d<||d<dddd|vr=t5t|ddtrdd |jg|d <ddd|S|S#1swYLxYw#1swY|SxYw) Nextra)job_idfuncr9r: description enqueued_at started_atzrq-jobrHrrr fingerprint) r setdefaultidr2r9r:rfrgr rh issubclassr)eventhintr8rcr%weak_jobs r?event_processorz._make_event_processor..event_processorxsj ?,.(("5!ffMMHH!jj#&?? ??,>+;CNN+KF<("(h/"  ,.d:.q13FG,02G+WE-(/ u -/.$/ sBC:)D:DDr`)rorps` r?r+r+vs8 rMc tj}t||jddd\}}tj||y)NrF)typehandled)client_options mechanism)rn)r'r5r options capture_event)rHr:clientrmrns r?rGrGsB  " " $F&~~E2KE4 U.rM),r,r'sentry_sdk.constsrsentry_sdk.apirsentry_sdk.integrationsrrrsentry_sdk.integrations.loggingrsentry_sdk.tracingr sentry_sdk.utilsr r r r rrq.queuer rq.timeoutsr rq.versionrrU rq.workerrrq.jobr ImportErrortypingrrrsentry_sdk._typesrrrrrr+rGr`rMr?rs )UU90+/0  !$7(N#KN#bB /A+ ) **+s BB