Ii'SSKrSSKrSSKrSSKrSSKJr SSKJr SSKJr SSK J r J r J r J r Jr SSKJr SSKJrJrJrJrJr SS KJrJrJr \R6"S 5r\ \ \\ 4/\4r\ \/\ \\ 44r "S S \!5r""S S\\5r#\"SS55r$\"SS\$55r%"SS5r&"SS\!5r'"SS\'5r(SS.S\S\\ S4S\ \\ 4S\ \)S\)S \ \S!\4S"jjr*SS.S#\S\\ S4S\ \\ 4S\)S\)S$\+S%\ S&\)S'\)S(\S)\S*\S \ \S!\ \4S+jjr,SS,.S-\S.\ \ S!\$4S/jjr-SS,.S-\S.\ \ S!\\\\ S4\ \\ 4\)\)44S0jjr.SS,.S-\S.\ \ S!\%4S1jjr/g)2N) dataclass)datetime)Enum)AnyCallableDictOptionalTuple)Redis) abort_jobs_ssdefault_queue_namein_progress_key_prefixjob_key_prefixresult_key_prefix)ms_to_datetimepoll timestamp_mszarq.jobsc\rSrSrSrg)ResultNotFoundN__name__ __module__ __qualname____firstlineno____static_attributes__r./venv/lib/python3.13/site-packages/arq/jobs.pyrrrrc,\rSrSrSrSrSrSrSrSr Sr g ) JobStatusz Enum of job statuses. deferredqueued in_progresscomplete not_foundrN) rrrr__doc__r%r&r'r(r)rrrr r#r#s" H FKHIrr#c\rSrSr%\\S'\\S4\S'\\\4\S'\ \S'\ \S'\ \ \S'\ \\S 'S S jr S r g )JobDef*function.argskwargsjob_try enqueue_timescorejob_idNcx[UR[5(a[UR5UlggN) isinstancer3floatintselfs r __post_init__JobDef.__post_init__4s' djj% ( (TZZDJ )r)r3)returnN)rrrrstr__annotations__r rrr9rr r<rrrr r,r,*sGM S/ cN L C= SM)rr,cH\rSrSr%\\S'\\S'\\S'\\S'\\S'Sr g) JobResult9successresult start_time finish_time queue_namerN) rrrrboolr@rrr?rrrr rBrB9s M KOrrBc \rSrSrSrSr\S4S\SSS\S \\ 4S jjr SS SS .S \\ S\ S\\ S\ 4Sjjjr S\\4SjrS\\4SjrS\4SjrSS S.S \\ S\ S\4SjjrS\4SjrSrg)JobBz" Holds data a reference to a job. r4_redis _queue_name _deserializerNr4redisz Redis[bytes]rOrPc4XlX lX0lX@lgr6rM)r;r4rQrOrPs r __init__ Job.__init__Is  &*rg?) poll_delay pole_delaytimeoutrUrVr>cZ# Ub[R"S[5 Un[U5ShvN nURR SS9IShvN nUR [UR-5 URURUR5 UR5IShvN upgSSS5IShvN W(a[X`RS9nUR(aURs $[!UR["[$R&45(a URe[)UR5eWc [+S5eUcGM:XA:dGMB[$R,"5eGNSGN4NN!,IShvN (df  N=f g7f)a Get the result of the job or, if the job raised an exception, reraise it. This function waits for the result if it's not yet available and the job is present in the queue. Otherwise ``ResultNotFound`` is raised. :param timeout: maximum time to wait for the job result before raising ``TimeoutError``, will wait forever :param poll_delay: how often to poll redis for the job result :param pole_delay: deprecated, use poll_delay instead NzI"pole_delay" is deprecated, use the correct spelling "poll_delay" insteadT transaction deserializerzmNot waiting for job result because the job is not in queue. Is the worker function configured to keep result?)warningswarnDeprecationWarningrrNpipelinegetrr4zscorerOexecutedeserialize_resultrPrDrEr7 ExceptionasyncioCancelledErrorSerializationErrorr TimeoutError) r;rWrUrVdelaytrvsinfos r rE Job.resultUsD  ! MM[]o $J + -%{{+++==(4;;67 $**DKK8ZZ\)>= )!:L:LM<<;;& i9O9O-PQQ++%,T[[99$H "u**,,+ -=*>===,s,F+F)FF)F+FF+AF4F 5F; F+F BF+(F+0F+F)F+ F F+F& F F& " F+c# UR5IShvN nU(dNURR[UR-5IShvN nU(a[ X R S9nU(aMURRURUR5IShvN nUcSO [U5Ul U$NNvN7f)za All information on a job, including its result if it's available, does not wait for the result. Nr[) result_inforNrarr4deserialize_jobrPrbrOr9r3)r;rnrlrms r rnJob.infos(,'7'7'9!9kkoont{{&BCCA&q7I7IJ kk(()9)94;;GGA!"ADJ ":CHs4C C:C CAC *C +C C  C c# URR[UR-5IShvN nU(a[ XR S9$gN7f)z Information about the job result if available, does not wait for the result. Does not raise an exception even if the job raised one. Nr[)rNrarr4rdrP)r;rls r rqJob.result_infosC ++//"3dkk"AB B %a6H6HI I Cs0AA Ac# URRSS9IShvN nUR[UR-5 UR[ UR-5 UR URUR5 UR5IShvN up#nSSS5IShvN W(a[R$W(a[R$W(a.U[5:a[R$[R$[R$GN NN|!,IShvN (df  N=f7f)z Status of the job. TrYN)rNr`existsrr4rrbrOrcr#r(r'rr%r&r))r;rk is_completeis_in_progressr3s r status Job.statuss;;''D'99R II'$++5 6 II,t{{: ; IId&& 479zz|1C .K :9 %% % (( ( ).)?9%% UYEUEU U&& &:2D :999sXED-EA>D4"D0#D4* E5D26A8E0D42E4E :D= ; E ErWrUc # UR5IShvN nU(aUR(aUR[5:aURR SS9IShvN nUR UR UR5 URUR URS05 UR5IShvN SSS5IShvN URR[UR[505IShvN URXS9IShvN gGN"NNnN`!,IShvN (df  Nu=fN@N*![Ra g[a gf=f7f)a Abort the job. :param timeout: maximum time to wait for the job result before raising ``TimeoutError``, will wait forever on None :param poll_delay: how often to poll redis for the job result :return: True if the job aborted properly, False otherwise NTrYr r|F)rnr3rrNr`zremrOr4zaddrcr rErfrgr)r;rWrUjob_inforks r abort Job.aborts $ 8>>LN+J{{+++==(($++6((4;;*:;jjl"">= kk}t{{LN.KLLL ++g+E E E#%=#>=== M F%%   sFD8AF(D;)F,A"ED=E FD?;FEF E2E3E7F;F=E?FEE  EFEF3F5 F>FFFc"SURS3$)Nz )r4r:s r __repr__ Job.__repr__s4;;-q))r)rPrOrNr4r6)rrrrr* __slots__rr?r DeserializerrSr8rrEr,rnrBrqr#rzrIrrrrrr rKrKBsCI .04 + + + +  - +*.(-FIim(-(->C(-W_`eWf(- (-T HV,  8I#6 'i'&9=RUhuo%Z^8*#*rrKc\rSrSrSrg)rhrNrrrr rhrhr!rrhc\rSrSrSrg)DeserializationErrorrNrrrr rrr!rr) serializer function_namer/.r0r1enqueue_time_msrr>cX0XUS.nUc[RnU"U5$![an[SUS35UeSnAff=f)N)tfaketzunable to serialize job "")pickledumpsrerh)rr/r0r1rrdataes r serialize_jobrsZ4O \D\\ V$ V #<]O1!MNTUUVs# A=Ar.rDrEstart_ms finished_msrefrHr4c  UUUUUUUUUU U S. n U c[Rn U "U 5$![a [R SU SS9 Of=fU R SSS9 U "U 5$![a [R SU SS9 gf=f) N) rrrrrrmrstftqidzerror serializing result of %sT)exc_infozunable to serialize resultF)rrmz:error serializing result of %s even after replacing result)rrreloggerwarningupdatecritical)r.r/r0r1rrDrErrrrHr4rrs r serialize_resultrs"       D\\ M$ M7tLM KK.%K8j$ jTVYdhi js!+A  A !A))B  B r[rr\c Uc[RnU"U5n[USUSUSUS[US5SSS9$![an[ S5UeSnAff=f)Nrrrrr)r.r/r0r1r2r3r4unable to deserialize job)rloadsr,rrerrr\drs r rrrrs}||  G OsV3S6cF'$0   G"#>?QFGs.A A AAcUc[RnU"U5nUSUSUSUSUS4$![an[S5UeSnAff=f)Nrrrrrr)rrrerrs r deserialize_job_rawr$sg|| G Ovqvqvqvqw66 G"#>?QFGs3 A A  AcJUc[RnU"U5n[USUSUSUS[US5SUSUS[US5[US 5UR S S 5UR S S 5S 9 $![ an[ S5UeSnAff=f)Nrrrrrrmrrrrz r) r1r.r/r0r2r3rDrErFrGrHr4z unable to deserialize job result)rrrBrrarerrs r rdrd0s|| N OcFsV3S6'$0cFS6%ag.&qw/uuS+.55{+   N"#EFAMNsA1B B" BB")0rfloggingrr] dataclassesrrenumrtypingrrrr r redis.asyncior constantsr rrrrutilsrrr getLoggerrr?bytes Serializerr RuntimeErrorrr#r,rBrKrhrr9rrIrrrrrdrrr rs !77ss55   : & tCH~&- . c3h/0  \ T"  ) )  )  F*F*R   - (,VV S/V cNVc] V  V$V V@(,** S/* cN* *  *  * *** ** *$*e_*ZIMGuGx /EGQWG&9= G  G' 5 G 3c3hc3hc 9: GLPN%N(<2HNT]Nr