ޠj'SSKrSSKrSSKrSSKrSSKJr SSKJr SSKJr SSK J r J r J r SSK Jr SSKJrJrJrJrJr SS KJrJrJr \R2"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)AnyCallableOptional)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__rB/var/www/html/gaurav/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'rrrrr!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) isinstancer1floatintselfs r __post_init__JobDef.__post_init__4s' djj% ( (TZZDJ )r)r1)returnN)rrrrstr__annotations__tuplerdictr7rrr:rrrrr*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=rrrrrBrB9s 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. r2_redis _queue_name _deserializerNr2redisz Redis[bytes]rOrPc4XlX lX0lX@lgr4rM)r9r2rQrOrPs 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?)warningswarnDeprecationWarningrrNpipelinegetrr2zscorerOexecutedeserialize_resultrPrDrEr5 ExceptionasyncioCancelledErrorSerializationErrorr TimeoutError) r9rWrUrVdelaytrvsinfos rrE 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_inforNrarr2deserialize_jobrPrbrOr7r1)r9rnrlrms rrnJob.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[)rNrarr2rdrP)r9rls rrqJob.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`existsrr2r rbrOrcr!r&r%rr#r$r')r9rk is_completeis_in_progressr1s rstatus 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)rnr1rrNr`zremrOr2zaddrcr rErfrgr)r9rWrUjob_inforks rabort 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 )r2r8s r__repr__ Job.__repr__s4;;-q))r)rPrOrNr2r4)rrrrr( __slots__r r=r DeserializerrSr6rrEr*rnrBrqr!rzrIrrrrrrrKrKBsCI .04 + + + +  - +*.(-FIim(-(->C(-W_`eWf(- (-T HV,  8I#6 'i'&9=RUhuo%Z^8*#*rrKc\rSrSrSrg)rhrNrrrrrhrhrrrhc\rSrSrSrg)DeserializationErrorrNrrrrrrrrr) serializer function_namer-.r.r/enqueue_time_msrr<cX0XUS.nUc[RnU"U5$![an[SUS35UeSnAff=f)N)tfaketzunable to serialize job "")pickledumpsrerh)rr-r.r/rrdataes r serialize_jobrsZ4O \D\\ V$ V #<]O1!MNTUUVs# A=Ar,rDrEstart_ms finished_msrefrHr2c  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-r.r/rrDrErrrrHr2rrs rserialize_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-r.r/r0r1r2unable to deserialize job)rloadsr*rrerrr\drs rrrrrs}||  G OsV3S6cF'$0   G"#>?QFGs.A A AAcUc[RnU"U5nUSUSUSUSUS4$![an[S5UeSnAff=f)Nrrrrrr)rrrerrs rdeserialize_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) r/r,r-r.r0r1rDrErFrGrHr2z unable to deserialize job result)rrrBrrarerrs rrdrd0s|| N OcFsV3S6'$0cFS6%ag.&qw/uuS+.55{+   N"#EFAMNsA1B B" BB")0rfloggingrr] dataclassesrrenumrtypingrrr redis.asyncior constantsr r r rrutilsrrr getLoggerrr@r=bytes Serializerr RuntimeErrorrr!r*rBrKrhrr?r7rrIrrrrrdrrrrs !**ss55   : & 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