KiB&UdZddlZddlZddlmZmZddlmZddlm Z ddl m Z m Z m Z ddlmZddlmZdd lmZmZdd lmZe rdd lmZdd lmZej4eZej:ed <GddZGddZ y)a#Result storage for task execution results. This module provides: - ClusterKeyValueStore: A RedisCluster-compatible key-value store - ResultStorage: An async context manager that wraps either ClusterKeyValueStore or py-key-value's RedisStore, managing connection pool lifecycle internally N)MappingSequence)AsyncExitStack) TracebackType) TYPE_CHECKINGAny SupportsFloat)Self) RedisStore)ConnectionPoolRedis) RedisCluster)RedisConnection)close_resourceloggerc eZdZdZdddededdfdZd ed edzdefd Zdd Zdd d ed edzde ee fdzfdZ dd d ed edzde e ee fdze dzffdZdddd edeee fd edzdedzddf dZdd d ed edzdefdZdd deed edzdee ee fdzfdZdd deed edzdee e ee fdze dzffdZddddeedeeee fd edzdedzddf dZdd deed edzdefdZy)ClusterKeyValueStoreaIA key-value store that works with RedisCluster. This store implements the AsyncKeyValue protocol from py-key-value, storing JSON-serialized data in Redis keys. It's designed to work with RedisCluster clients where py-key-value's RedisStore doesn't. The store uses a simple key structure: {collection}:{key} default)default_collectionclientrreturnNc ||_||_y)zInitialize the cluster key-value store. Args: client: A RedisCluster client to use for storage default_collection: The default collection name for keys N)_client_default_collection)selfrrs `/home/jay/workspace/scripts/.codegraph-venv/lib/python3.12/site-packages/docket/_result_store.py__init__zClusterKeyValueStore.__init__(s #5 key collectionc0||n |j}|d|S)z1Build the full Redis key from collection and key.:)r)rrr colls r _make_keyzClusterKeyValueStore._make_key7s$'3z9Q9Qqrc Kyw)z.Initialize the store. No-op for cluster store.Nrs rsetupzClusterKeyValueStore.setup<  r cK|j||}|jj|d{}|ytj|S7w)z6Retrieve a value by key from the specified collection.N)r$rgetjsonloads)rrr redis_keydatas rr-zClusterKeyValueStore.get@sKNN3 3 \\%%i00 <zz$1s1AAAcK|j||}|jj|d{}|y|jj|d{}|dk\r t |nd}t j ||fS7S7/w)z%Retrieve the value and TTL for a key.N)NNr)r$rr-ttlfloatr.r/)rrr r0r1ttl_val ttl_floats rr3zClusterKeyValueStore.ttlMs~NN3 3 \\%%i00 < ((334;qL%.d zz$** 14s!1B B%B B .B  B r r3valuer3c"K|j||}tj|}|:tt |}|j j |||d{y|j j||d{y7*7w)z)Store a key-value pair with optional TTL.N)r$r.dumpsintr4rsetexset)rrr8r r3r0r1 ttl_secondss rputzClusterKeyValueStore.put]sxNN3 3 zz%  ?eCj/K,,$$Y TB B B,,""9d3 3 3 C 3s$AB B !$BB B BcK|j||}|jj|d{}|dkDS7 w)zDelete a key-value pair.Nrr$rdelete)rrr r0results rrBzClusterKeyValueStore.deletens>NN3 3 ||**955z6s 1?= ?keyscK|sgS|Dcgc]}|j||}}|jj|d{}|Dcgc]}|tj|ndc}Scc}w70cc}ww)z Retrieve multiple values by key.N)r$rmgetr.r/)rrDr k redis_keysvaluesvs rget_manyzClusterKeyValueStore.get_manyyssI=ABdnnQ 3B B||((44BHIQ 1 D8IIC4Is- A<A0 A<A5A< A7- A<7A<cK|sgSg}|D]3}|j||d{\}}|j||f5|S7w)z(Retrieve multiple values and their TTLs.r+N)r3append)rrDr resultsrvalr5s rttl_manyzClusterKeyValueStore.ttl_manysZIDF +C!%#*!EELC NNC> * +Fs"AAArIc|K|syt||dD]"\}}|j||||d{$y7w)zStore multiple key-value pairs.NT)strictr7)zipr?)rrDrIr r3rr8s rput_manyzClusterKeyValueStore.put_manysI dF48 GJC((3*#(F F F G Fs 0<:<cK|sy|Dcgc]}|j||}}|jj|d{Scc}w7 w)z Delete multiple key-value pairs.rNrA)rrDr rGrHs r delete_manyz ClusterKeyValueStore.delete_manysO=ABdnnQ 3B B(T\\((*555C5sA AA A  A rN)__name__ __module__ __qualname____doc__rstrrr$r(dictrr-tupler4r3rr r?boolrBrlistrKrPrTr;rVr&rrrrsc#, 6 6 6  6ScDjS  "&    $J  c3h$   ""& + +$J + tCH~$edl2 3 +*"&$( 4 4sCx 4 $J 4 T ! 4 4*"&   $J   "& Jsm J$J J d38nt# $ J""& sm $J  eDcNT)54<78 9 ("&$( Gsm Gc*+ G $J G T ! G  G$"& 6sm 6$J 6 6rrc VeZdZUdZeezed<eed<eed<e ed<ddde d d fd Z d e fd Z d eed zded zded zd d fdZd"dZd dde de d zd ee efd zfdZd dde de d zd eee efd zed zffdZd d dde dee efde d zded zd d f dZd dde de d zd efdZd ddee de d zd eee efd zfdZ d ddee de d zd eeee efd zed zffdZ!d d ddee deee efde d zded zd d f d Z"d ddee de d zd e#fd!Z$y )# ResultStoragea5Result storage that implements AsyncKeyValue using a RedisConnection. This class wraps either a ClusterKeyValueStore (for cluster mode) or a RedisStore (for standalone mode). It creates its own connection pool for standalone mode (with decode_responses=True) using the RedisConnection's URL. _store_poolr_stackredisrrrNc ||_||_yN)_redisr)rrfrs rrzResultStorage.__init__s  #5 rcKt_jjd{jjrRjj t dtjj j_ njjdd{_ jjfdjjtjdtj_jjfdjjtj d t#j j_ jj%d{S777 w) Nz-RedisConnection not connected in cluster mode)rrT)decode_responsesctdS)Nrddelattrr'srz*ResultStorage.__aenter__..sw)?rpool)connection_poolctdS)Nrrmr'srroz*ResultStorage.__aenter__..sy)Arr)rre __aenter__ri is_clustercluster_client ValueErrorrrrc_connection_pool_from_urlrdcallbackpush_async_callbackrr rr r(r's`rrszResultStorage.__aenter__sM$& kk$$&&& ;; ! !{{))1 !PQQ.{{11#'#;#;DK ${{DD!% E DJ KK !? @ KK + +NDJJ O 
rsl -%44"1/.-(***844O6O6dFJFJr