s,gddlZddlmZmZddlmZmZddlmZddlm Z m Z ddl m Z ddl mZdd lmZdd lmZdd lmZmZd ZGd dZy)N) b64decode b64encode)datetimetimezone)Enum)AnyOptional)Redis)#UNSERIALIZABLE_RETURN_VALUE_PAYLOAD)Job)resolve_serializer)decode_redis_hashnowc d|zSNz rq:results:%s)job_ids d/var/www/trellinator.diamondhoofcare.com/public_html/venv/lib/python3.12/site-packages/rq/results.pyget_keyrs V ##ceZdZGddeZ d dedededeedeed ee d eefd Z d Z d Z dZ ed!d"dZed#d"dZed#d"dZed#defdZededefdZededdfdZed#dededededdf dZed#dededfdZed$dedededfdZedZd#dZdZy)%ResultceZdZdZdZdZdZy) Result.Typer N)__name__ __module__ __qualname__ SUCCESSFULFAILEDSTOPPEDRETRIEDrrrTypers rr&Nrtype connectionid created_at return_value exc_stringc ||_||_||_|r|n t|_t ||_||_||_||_ yN) r+r,r'rr*r serializerr(rr)) selfrr'r(r)r*r+r,r/s r__init__zResult.__init__sH)$ (2*,Z8$ rcnd|jd|j|jjdS)Nz Result(id=z, type=))r)r&r'namer0s r__repr__zResult.__repr__.s/DGG9GDIIdii,@,E,E+FaHHrcT |j|jk(S#t$rYywxYw)NF)r)AttributeError)r0others r__eq__z Result.__eq__1s, 77ehh& &  s  ''c,t|jSr.)boolr)r5s r__bool__zResult.__bool__7sDGG}rreturnc||j||j|||j}|j|||S)N)rr'r(r+r,r/ttlpipeline)r)r(r/save)clsjobr'rAr+r,rBresults rcreatez Result.create:sA66~~%!~~    h / rc||j|jj|j||j}|j |||S)N)rr'r(r,r/r@)r)r&r#r(r/rC)rDrErAr,rBrFs rcreate_failurezResult.create_failureGsF66~~!~~    h / rc||j|jj|j|j}|j |||S)N)rr'r(r/r@)r)r&r%r(r/rC)rDrErArBrFs rcreate_retriedzResult.create_retriedSsE66!!~~~~    h / rrEc |jj|j|jdd}g}|D]L\}}|j |j |j|j ||j|N|S)zReturns all results for job+-r(r/)r( xrevrangerr)appendrestoredecode)rDrEr/responseresults result_idpayloads rallz Result.all^s}>>++CKK,?cJ"*  Iw NN CFFI$4$4$6CNNgq r   rcj|jj|j|jS)z!Returns the number of job results)r(xlenrr)rDrEs rcountz Result.countks&~~""3;;svv#677rcl|jj|j|jy)zDelete all job resultsN)r(deleterr)r[s r delete_allzResult.delete_allps# ckk#&&12rrVrWc  tjt|jdddz tj }t |}t|}|jd}|(|jt|j}|jd}|r,tjt|j}t|tjt|d|||||S) z/Create a Result object from given Redis payloadrNr)tzr+r,r')r(r)r*r+r,)r fromtimestampintsplitrutcrrgetloadsrrSzlib decompressrr&) rDrrVrWr(r/r*r+r,s rrRzResult.restoreus++C 0DQ0G,H4,OT\T`T`a #G, ( 3 {{>2  #%++Il6I6I6K,LML[[. :)>?FFHJ  KKGFO, -!!%!  rcy)afFetch a result that matches a given job ID. The current sorted set based implementation does not allow us to fetch a given key by ID so we need to iterate through results, deserialize the payload and look for a matching ID. Future Redis streams based implementation may make this more efficient and scalable. Nr)rDrEr/s rfetchz Result.fetchsrtimeoutc|rS|dz}|jj|j|jdi|}|sy|d}|d}|d\}}nC|jj |j|jdd d }|sy|d\}}|j |j|j ||j| }|S) zReturns the latest result for given job instance or ID. If a non-zero timeout is provided, block for a result until timeout is reached. raz0-0)blockNrr rMrN)r\rO)r(xreadrr)rPrRrS) rDrEr/rm timeout_msrTrVrWress r fetch_latestzResult.fetch_latests !4J~~++S[[-@%,HPZ+[H{H{H!)" Iw~~// CFF0CS#UV/WH!)! Iwkk#&&)"2"2"4g#..eokp rc d|zSrr)rDrs rrzResult.get_keys ''rcN|j|j}||n |j}|j||j d}||j |_|4|dk(r|j||j S|j|||j S)zSave result data to Redis )maxlenrp) rrr(xadd serializerSr)persistexpire)r0rArBkeyr(rFs rrCz Result.savesll4;;'!)!5X4?? dnn&6rB  mmoDG ?by""3'ww!!#s+wwrcd|jji}|jGtt j |jj j|d< |jj|j}|jt|j|d<|S#|jjt}YMxYw)Nr'r,r+) r'valuer,rricompressencoderSr/dumpsr+r )r0data serializeds rrzzResult.serializes ( ?? &!*4==9O9O9Q+R!S!Z!Z!\D  T..t/@/@AJ    (#,Z#8#?#?#AD   T../RSJs -%B<rr.)Nr)rr r!rr&strr r rrr1r6r:r= classmethodrGrIrKr rXrdr\r_dictrRrlrtrrCrzrrrrrst!)-&*$(  SM  X& smSM(I      c  88883S3T33 S S 4 U hp  6  (1C  sc(S[J\4(("rr)ribase64rrrrenumrtypingrr redisr defaultsr rEr serializersrutilsrrrrrrrrs4 '' 9+)$IIr