o Zh@s<ddlmZddlZddlmZddlmZddlmZddl m Z m Z ddl m Z ddlmZdd lmZmZmZmZz dd lmZdd lmZdd lmZdd lmZddlmZWn e yge dwddl!m"Z"e"rddl#m$Z$m%Z%ddl!m&Z&m'Z'ddlm(Z(ddlm)Z)Gddde Z*ddZ+ddZ,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)Worker) JobStatuszRQ not installed) TYPE_CHECKING)AnyCallable)EventEventProcessor)ExcInfo)Jobc@seZdZdZeddZdS) RqIntegrationrqcstt}|durtdt|dkrtdtjfdd}|t_tjfdd}|t_tjfdd }|t_t d dS) NzUnparsable RQ version: {})rzRQ 0.6 or newer is required.c s.tj}|t}|dur||g|Ri|S|j}|dus!J|a}||tt |t |j dp.sentry_patched_perform_jobcs2|jtjks |jr t|||g|Ri|S)N)Z_statusrZFAILEDZ is_failed_capture_exception)r,r-exc_infor/)old_handle_exceptionr4r5sentry_patched_handle_exceptionaszARqIntegration.setup_once..sentry_patched_handle_exceptioncsDtj}|tdur|jjdurt||jd<||fi|S)Nr) rr"r#rr1spandictZiter_trace_propagation_headersr()r,r-r/r0)old_enqueue_jobr4r5sentry_patched_enqueue_jobns  z.sentry_patched_enqueue_jobz rq.worker) r RQ_VERSIONrformatrZ perform_jobZhandle_exceptionrZ enqueue_jobr)versionr6r:r>r4)r=r9r3r5 setup_once)s &    zRqIntegration.setup_onceN)__name__ __module__ __qualname__ identifier staticmethodrBr4r4r4r5r&srcsfdd}|S)Ncs}|durEt3|di}|j|j|j|j|jd}|jr(t|j|d<|j r2t|j |d<||d<Wdn1s@wYd|vrvt"t |ddt rfdd |jg|d <Wd|SWd|S1sqwY|S) Nextra)Zjob_idfuncr.r/ description enqueued_at started_atzrq-jobr8rrr fingerprint) r setdefaultidr*r.r/rJrKr rL issubclassr)eventhintr-rHr!weak_jobr4r5event_processors6    z._make_event_processor..event_processorr4)rTrUr4rSr5r%~s r%cKsJtj}|tdur dS|j}t||jdddd\}}|j||ddS)NrF)typeZhandled)Zclient_optionsZ mechanism)rR)rr"r#rr$r optionsZ capture_event)r8r/r0r$rQrRr4r4r5r7s r7)- __future__rr&Zsentry_sdk.constsrZsentry_sdk.apirZsentry_sdk.hubrZsentry_sdk.integrationsrrZsentry_sdk.integrations.loggingrZsentry_sdk.tracingr Zsentry_sdk.utilsr r r r Zrq.queuerZ rq.timeoutsrZ rq.versionrr?Z rq.workerrZrq.jobr ImportErrorZsentry_sdk._typesrtypingrrrrrrrr%r7r4r4r4r5s6              X !