+ hc s^RIt^RIt^RIt^RIt^RIt^RIt^RIHtHtH t H t H t H t H t HtHtHtHtHt^RIHtHt^RIHtHtHt^RIHt^RIHtHtHtH t ^RI!H"t"^RI#H$t$^R I%H&t&^R I'H(t(H)t)H*t*^R I+H,t,H-t-H.t.H/t/H0t0H1t1H2t2H3t3H4t4^R I5H6t6H7t7^R I8H9t9H:t:^RI;Ht>H?t?H@t@HAtAHBtBHCtCHDtDHEtEHFtFHGtGHHtHHItIHJtJHKtKHLtL^RIMHNtNHOtOHPtP^RIQHRtRHStSHTtTHUtUHVtV]!R]WR] R,] ]R3,4tX!RR]4tY!RR]*]0]74tZ!RR4t[!RR4t\!RR]*]0]74t]],F<t^]^PRR4P4t^]^R8XdK,]a!]]]^]2!]^44K> !R R!4tbR#)"N) AnyCallableDequeDict GeneratorListMappingOptionalTupleTypeTypeVarUnion)AsyncCommandsParserEncoder)_RedisCallbacks_RedisCallbacksRESP2_RedisCallbacksRESP3)ResponseCallbackT) Connection DefaultParser SSLConnection parse_urlLock)Retry)default_backoff)EMPTY_RESPONSE NEVER_DECODE AbstractRedis) PIPELINE_BLOCKED_COMMANDSPRIMARYREPLICASLOT_IDAbstractRedisCluster LoadBalancerblock_pipeline_command get_node_nameparse_cluster_slots) READ_COMMANDSAsyncRedisClusterCommands)REDIS_CLUSTER_HASH_SLOTSkey_slot)CredentialProvider)AskErrorBusyLoadingErrorClusterCrossSlotErrorClusterDownError ClusterErrorConnectionError DataErrorMasterDownErrorMaxConnectionsError MovedErrorRedisClusterException ResponseErrorSlotNotCoveredError TimeoutError TryAgainError)AnyKeyT EncodableTKeyT)deprecated_function dict_mergeget_lib_versionsafe_str str_if_bytes TargetNodesT ClusterNodecsT]tRt^Ot]!]P R]R]R] R] R] R] /4tRt R#) ClusterParserZASKZ CLUSTERDOWNZ CROSSSLOTZ MASTERDOWNZMOVEDZTRYAGAINN)__name__ __module__ __qualname____firstlineno__r?rZEXCEPTION_CLASSESr,r/r.r3r5r:__static_attributes__rF:/usr/lib/python3.14/site-packages/redis/asyncio/cluster.pyrErEOs;"'' 8 + . / Z    rLrEc&s4a]tRt^]toRt]V3RlRl4tRQtRRRRR^^^RR^RRRRRR]!4R R R^RRRRRRRRRR RRRRR^R3&V3R lR llt V3RlRlt V3RlRlt ] !RRRR7V3RlRl4t V3RlRltV3RlRltV3RlRltRt]P&]P*3V3RlR lltV3R!lR"ltV3R#lR$ltV3R%lR&ltV3R'lR(ltV3R)lR*ltV3R+lR,ltV3R-lR.ltRSV3R/lR0lltRTV3R1lR2lltV3R3lR4lt V3R5lR6lt!V3R7lR8lt"V3R9lR:lt#V3R;lR<lt$V3R=lR>lt%R?R/V3R@lRAllt&V3RBlRClt'V3RDlRElt(V3RFlRGlt)V3RHlRIlt*V3RJlRKlt+RUV3RLlRMllt,RVV3RNlROllt-RPt.Vt/R#)W RedisClustera/ Create a new RedisCluster client. Pass one of parameters: - `host` & `port` - `startup_nodes` | Use ``await`` :meth:`initialize` to find cluster nodes & create connections. | Use ``await`` :meth:`close` to disconnect connections & close client. Many commands support the target_nodes kwarg. It can be one of the :attr:`NODE_FLAGS`: - :attr:`PRIMARIES` - :attr:`REPLICAS` - :attr:`ALL_NODES` - :attr:`RANDOM` - :attr:`DEFAULT_NODE` Note: This client is not thread/process/fork safe. :param host: | Can be used to point to a startup node :param port: | Port used if **host** is provided :param startup_nodes: | :class:`~.ClusterNode` to used as a startup node :param require_full_coverage: | When set to ``False``: the client will not require a full coverage of the slots. However, if not all slots are covered, and at least one node has ``cluster-require-full-coverage`` set to ``yes``, the server will throw a :class:`~.ClusterDownError` for some key-based commands. | When set to ``True``: all slots must be covered to construct the cluster client. If not all slots are covered, :class:`~.RedisClusterException` will be thrown. | See: https://redis.io/docs/manual/scaling/#redis-cluster-configuration-parameters :param read_from_replicas: | Enable read from replicas in READONLY mode. You can read possibly stale data. When set to true, read commands will be assigned between the primary and its replications in a Round-Robin manner. :param reinitialize_steps: | Specifies the number of MOVED errors that need to occur before reinitializing the whole cluster topology. If a MOVED error occurs and the cluster does not need to be reinitialized on this current error handling, only the MOVED slot will be patched with the redirected node. To reinitialize the cluster on every MOVED error, set reinitialize_steps to 1. To avoid reinitializing the cluster on moved errors, set reinitialize_steps to 0. :param cluster_error_retry_attempts: | Number of times to retry before raising an error when :class:`~.TimeoutError` or :class:`~.ConnectionError` or :class:`~.ClusterDownError` are encountered :param connection_error_retry_attempts: | Number of times to retry before reinitializing when :class:`~.TimeoutError` or :class:`~.ConnectionError` are encountered. The default backoff strategy will be set if Retry object is not passed (see default_backoff in backoff.py). To change it, pass a custom Retry object using the "retry" keyword. :param max_connections: | Maximum number of connections per node. If there are no free connections & the maximum number of connections are already created, a :class:`~.MaxConnectionsError` is raised. This error may be retried as defined by :attr:`connection_error_retry_attempts` :param address_remap: | An optional callable which, when provided with an internal network address of a node, e.g. a `(host, port)` tuple, will return the address where the node is reachable. This can be used to map the addresses at which the nodes _think_ they are, to addresses at which a client may reach them, such as when they sit behind a proxy. | Rest of the arguments will be passed to the :class:`~redis.asyncio.connection.Connection` instances when created :raises RedisClusterException: if any arguments are invalid or unknown. Eg: - `db` != 0 or None - `path` argument for unix socket connection - none of the `host`/`port` & `startup_nodes` were provided c*<V^8dQhRS[RS[RR/#)urlkwargsreturnrN)strrZformat __classdict__"rM __annotate__RedisCluster.__annotate__s"3#.rLc sVP\V44VPRR4\JdRVR&V!R/VB#)aI Return a Redis client object configured from the given URL. For example:: redis://[[username]:[password]]@localhost:6379/0 rediss://[[username]:[password]]@localhost:6379/0 Three URL schemes are supported: - `redis://` creates a TCP socket connection. See more at: - `rediss://` creates a SSL wrapped TCP socket connection. See more at: The username, password, hostname, path and all querystring values are passed through ``urllib.parse.unquote`` in order to replace any percent-encoded values with their corresponding characters. All querystring options are cast to their appropriate Python types. Boolean arguments can be specified with string values "True"/"False" or "Yes"/"No". Values that cannot be properly cast cause a ``ValueError`` to be raised. Once parsed, the querystring arguments and keyword arguments are passed to :class:`~redis.asyncio.connection.Connection` when created. In the case of conflicting arguments, querystring arguments are used. connection_classNTsslrF)updaterpopr)ZclsrQrR&&,rMfrom_urlZRedisCluster.from_urls=8  in% ::($ /= @ F5M}V}rLNiTFzredis-pyzutf-8ZstrictZrequiredcQs><V^8dQhRS[S[,RS[S[S[3,RS[S[R,,RS[RS[RS[RS[R S[R S[R S[S[S[3,R S[S[,R S[S[,RS[S[,RS[S[,RS[S[,RS[S[,RS[S[,RS[RS[RS[RS[RS[S[,RS[RS[S[S[S[S[S[ 3,3,,RS[S[,RS[R,RS[S[S[ S[ ,,,RS[RS[S[,R S[S[,R!S[R"S[S[,R#S[R$S[S[,R%S[S[ P,R&S[S[,R'S[S[,R(S[S[S[S[S[3,.S[S[S[3,3,,R)R*/'#)+rPhostport startup_nodesrDrequire_full_coverageread_from_replicasreinitialize_stepscluster_error_retry_attemptsconnection_error_retry_attemptsmax_connectionsdbpathcredential_providerusernamepassword client_namelib_name lib_versionencodingencoding_errorsdecode_responseshealth_check_intervalsocket_connect_timeoutsocket_keepalivesocket_keepalive_optionssocket_timeoutretryrretry_on_errorr[ ssl_ca_certs ssl_ca_data ssl_cert_reqs ssl_certfilessl_check_hostname ssl_keyfilessl_min_version ssl_ciphersprotocol address_remaprSN)rrTr intrboolr+floatrZbytesr Exceptionr[Z TLSVersionrr rUrWrMrXrYse2e2sme2CHoe2  ] 34 e2 $ e2!e2 e2'*e2*-e2e2 #s(Oe2sme2&&89e2 3-!e2"3-#e2$c]%e2&3-'e2(c])e2,-e2./e201e24 %5e26!)7e289e2:#+73c5j8I3I+J"K;e2<!=e2> ?e2@!d9o!67Ae2DEe2FsmGe2Hc]Ie2JKe2LsmMe2N!Oe2Pc]Qe2R"#..1Se2Tc]Ue2V3-We2X %S/):E#s(O)K LMYe2Z [e2rLc'sV 'd \R4hV 'd \R4hV'd V'gV'g \R4h/RV bR\bR\bRV bRV bRVbR VbR VbR VbR VbR VbRVbRVbRVbRVbRVbRVbRVRV%/Cp'V'd(V'PR\RVRVRVRV RV!RV"RV#RV$/ 4V'dVP V'R&VVnV'gV'gV^8dpT;'g\\4V4VnV'g \\.pVP PV4V'PRVP /4\P!4V'R&V'PR4R%9dV'R,P\4MV'R,P\ 4V'VnV'dI.p(VF=p)V(P%\'V)P(V)P*3/VP"B4K? T(pM.pV'd.V'd&VP%\'W3/VP"B4\-VVV'V&R 7Vn\1VVV4VnWPnW`nWpnWn^Vn\?4Vn VPBPDP4Vn#VPBPHP4Vn%V'R,Vn&VPBPNP4Vn(R!VPPR"&R#Vn)R$Vn*R$#)&z/Argument 'db' must be 0 or None in cluster modez3Unix domain socket is not supported in cluster modea1RedisCluster requires at least one node to discover the cluster. Please provide one of the following or use RedisCluster.from_url: - host and port: RedisCluster(host="localhost", port=6379) - startup_nodes: RedisCluster(startup_nodes=[ClusterNode("localhost", 6379), ClusterNode("localhost", 6380)])rhrZZ parser_classrkrlrmrnrorprqrrrsrtrurvrwrxryrr{r|r}r~rrrrZredis_connect_funcresponse_callbacksrcsV\\VP44^,3/VB#)r)r&listvalues)cmdresrRr^rMZZ'RedisCluster.__init__..s%':SZZ\"1%()/(rL CLUSTER SLOTSTN)Z3)+r6rrEr\r on_connectryrrr1r9Zupdate_supported_errorsrZcopygetrrconnection_kwargsappendrDr`ra NodesManager nodes_managerrencoderrdrerfrgreinitialize_counterr commands_parser __class__Z NODE_FLAGS node_flagsZ COMMAND_FLAGS command_flagsrZRESULT_CALLBACKSresult_callbacks _initialize_lock)*selfr`rarbrcrdrerfrgrhrirjrkrlrmrnrorprqrrrsrtrurvrwrxryrzr[r{r|r}r~rrrrrrrRZ passed_nodesnodes*&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& rM__init__ZRedisCluster.__init__s\ 'A  'E D-'S " "  "  M" "#6 "  "  "  ;"  "  ;"  "  "   0" $%:!" " %&<#" $  0%" & '(@'" ( n)" * U -" 2  MM& "L!;#]"L(*<!;%!;   +/??F' ( N&E&I%!#B#DJ""1 MM7DJJ/ 0'6';';'=#$ ::j !X - ' ( / /0D E ' ( / /0D E!' L%## 499O8N8NO&)MM D  T!R4;Q;Q!R S)  ! '   x:JK "4"4,H)/N,$%!24..3388:!^^99>>@"()="> $ ? ? D D F  o.  -1 rLc<V^8dQhRR/#rPrSrNrFrUrWrMrXrYs.rLc s"VP'dVP'g\P!4VnVP;_uu_4GRjxL VP'dbVPP 4GRjxL VP P VPP4GRjxL RVnRRR4GRjxL V#V#LLXL# \dJTPP4GRjxL TPPR4GRjxL hi;iLe +GRjxL 'giT#;i5i)zJGet all nodes from startup nodes & creates connections if not initialized.NFrb) rrasynciorr initializer default_node BaseExceptionacloser&rMrZRedisCluster.initializes     :::$\\^ zzzz### "00;;==="22== ..;;,1("z t ">)"0077999"0077HHH"zzz s$E!2E!C%E!E1C+C'6C+C) C+ E!E E!'C+)C++(D?D #D?7D: 8D??EE!E E  E E  E!crrPrSNrFrUrWrMrXrYs E Ed ErLc s"VP'gVP'g\P!4VnVP;_uu_4GRjxL VP'gMRVnVPP 4GRjxL VPP R4GRjxL RRR4GRjxL R#R#LvL=LL +GRjxL 'giR#;i5i)z.Close all connections & client if initialized.NTrb)rrrrrrrrrMrZRedisCluster.acloses:::$\\^ zzzz''''+D$,,33555,,33ODDD "zz "6D "zzzsv$C52C5CC57CC"C7C8C< C5C C5CCC5C2 C! C2 *C2 , C5z5.0.0zUse aclose() insteadclose)ZversionZreasonnamecrrrFrUrWrMrXrYsTrLc sB"VP4GRjxL R#L5i)z.alias for aclose() for backwards compatibilityNrrrrMrZRedisCluster.closeskkm crrrFrUrWrMrXrYs''.'rLc>"VP4GRjxL #L5iNrrrrM __aenter__ZRedisCluster.__aenter____&&&& c*<V^8dQhRRRRRRRR/#rPexc_typeN exc_value tracebackrSrFrUrWrMrXrYs*$SWrLcsB"VP4GRjxL R#L5irrrrrr&&&&rM __aexit__ZRedisCluster.__aexit__skkmrc6<V^8dQhRS[S[RR3,/#)rPrSNrNrrrUrWrMrXrYs --9S$%>?-rLc>VP4P4#rr __await__rrrMrZRedisCluster.__await__ **,,rLzUnclosed RedisCluster clientc*<V^8dQhRS[RS[RR/#rP_warn_grlrSNrrUrWrMrXrYs)      rLcs\VR4'd]VP'gIV!VP RV: 2\VR7RVRVP/pV!4P V4R#R#R# \ dR#i;i)r ZsourceclientmessageN)Zhasattrr _DEL_MESSAGEResourceWarningcall_exception_handler RuntimeError)rrrcontexts&&& rM__del__ZRedisCluster.__del__s 4 ' '0@0@0@ T&&'q1?4 P #T9d6G6GH--g6 1A '    s&A11 B?Bc$<V^8dQhRS[RR/#)rP connectionrSNrrUrWrMrXrYs = =: =$ =rLcs"VP4GRjxL VPR4GRjxL \VP4GRjxL 4R8wd \ R4hR#LPL9L5i)NZREADONLYZOKzREADONLY command failed)rZ send_commandrB read_responser1rr&&rMrZRedisCluster.on_connectse##%%%%%j111 j6688 9T A!";< < B & 28s1A-A'A-A)A- A+ A-)A-+A-c.<V^8dQhRS[R,/#rPrSrDrrUrWrMrXrYs==4 .=rLc s\\VPPP44#)zGet all nodes of the cluster.)rr nodes_cacherrrrM get_nodesZRedisCluster.get_nodess"D&&2299;<'?&rLc r)zGGet the kwargs passed to :class:`~redis.asyncio.connection.Connection`.)rrrrMget_connection_kwargsZ"RedisCluster.get_connection_kwargs"s%%%rLcr)rPrSr)rrUrWrMrXrY&s8G,rLcrr)ryrrrM get_retryZRedisCluster.get_retry&s zzrLcr)rPryrrSNrFrUrWrMrXrY)s##w#4#rLcsWnVP4F9pVPPRV/4VPF pWnK K; R#)ryN)ryrrr\ _connections)rryrZconns&& rM set_retryZRedisCluster.set_retry)sF NN$D  " " ) )7E*: ;))" *%rLcrO)rPcommandcallbackrSN)rTrrUrWrMrXrY0s$44S4<<Q( (/33dsc"d3 u:?')DE yy{1G$4s+CFF FA*FF!1FFcr)rP target_nodesrSrrrUrWrMrXrYsQQ#Q$QrLcsN\V\4;'dWP9#r) isinstancerTr)rrrrM _is_node_flagZRedisCluster._is_node_flags,,PP1PPrLc4<V^8dQhRS[RS[R,/#)rPrrSrD)rrrUrWrMrXrYs ]8KrLcs\V\4'dTpV#\V\4'dV.pV#\V\4'd\VP 44pV#\ R\ V4 24h)ztarget_nodes type can be one of the following: node_flag (PRIMARIES, REPLICAS, RANDOM, ALL_NODES),ClusterNode, list, or dict. The passed type is )rrrDdictr TypeErrortype)rrnodes&& rM_parse_target_nodesZ RedisCluster._parse_target_nodess lD ) ) E   k 2 2!NE  d + +,,./E &'+<&8%9; rLcs,<V^8dQhRS[RS[RS[/#rPr rRrS)r<rrUrWrMrXrYs'RR:RRRrLc s&aaa"S^,p.pRpSPpSPRR4pV'd-SPV4'gSPV4pRp^p^V,p\ V4EFp SP 'dUSP 4GRjxL \V4^8Xd-V^,SP48XdSP4V'g2SP!SRV/GRjxL pV'g\RS R24h\V4^8XdjSP!V^,.SO5/SBGRjxL p VSP9d0SPV,!W4^,PV /3/SBu#V u#VU u.uFqPNK p p \P !VVV3RlV4!GRjxL p VSP9d0SPV,!V\#\%W443/SBu#\#\%W44u# R#ELEL4Luup iLk \&dCpT^8d5\)T4SP*P,9dT^,pRp?EKThRp?ii;i5i) a Execute a raw command on the appropriate cluster node or target_nodes. It will retry the command as specified by :attr:`cluster_error_retry_attempts` & then raise an exception. :param args: | Raw command args :param kwargs: - target_nodes: :attr:`NODE_FLAGS` or :class:`~.ClusterNode` or List[:class:`~.ClusterNode`] or Dict[Any, :class:`~.ClusterNode`] - Rest of the kwargs are passed to the Redis connection :raises RedisClusterException: if target_nodes is not provided & the command can't be mapped to a slot FrNTr !No targets were found to execute command onc3sx<"TF/p\P!SP!V.SO5/SB4xK1 R#5ir)r create_task_execute_command).0rr rRrs& rM Z/RedisCluster.execute_command..sD)5$// $ 5 5d LT LV L)5s7:)rfr]rrrangerrrrreplace_default_noder r6rrrrgatherrZziprrrERRORS_ALLOW_RETRY)rr rRrrZtarget_nodes_specifiedZretry_attemptspassed_targetsZexecute_attempts_retrrresfjl rMexecute_commandZRedisCluster.execute_commandss$q' !&::ND9 $"4"4^"D"D33NCL%) "N~-'(Aoo''' %*$Q4+@+@+BB--/* -)-)>)>*)7*$L(3?v[Q|$) $ 5 5l1o W WPV WWC$"7"77#44W=#1o&:&:C%@ DJ J2>?,$II,D?#*>>)5 $F$"7"77#44W=#T#d*;%< @F  D 122U)'$X@ !A%$q'T^^5V5V*V#a'NG sA JAJ"H2#AJ$I,IH5 I?I H8AIJIJIH:.%IH?AIJI+J5I8I:I J 4J JJ  JJcsF<V^8dQhRRRS[S[S[3,RS[RS[/#)rP target_noderDr rRrSr r=r<rrUrWrMrXrYs=F-F-(F-16tZ7G1HF-TWF- F-rLcs^"R;rERpVPpV^8dV^,pV'd/VPVR7pVPR4GRjxL RpM_V'dXVP!V!GRjxL pVPP YP ;'dV^,\94pRpVP!V/VBGRjxL #\9R4hLLjL \\3dh\\3dLTPPPTPR4TP4GRjxL h\ d;TP4GRjxL \"P$!R4GRjxL h\&dp T;P(^, unTP*'dDTP(TP*,^8Xd"TP4GRjxL ^TnMYPnRpRp ? EKRp ? i\.d0p \1T P2T P4R7pRpRp ? EKIRp ? i\6d@YpP^, 8d$\"P$!R4GRjxL EKEKi;i5i) FNrZASKING?Tr`rag?zTTL exhausted.)ZRedisClusterRequestTTLrr)r rr rdr'r-r4r1r9rbr]rrr/rsleepr5rre_moved_exceptionr,r%r`rar:r0) rr*r rRZaskingZmovedZ redirect_addrZttlrr(s &&*, rMrZRedisCluster._execute_commands. ))Ag 1HC; ."&----"HK%55h???"F"&!5!5t!<H?H%J-% J*2J*3#IJ- J**1J*JJ*!J-)J**J-csJ<V^8dQhRS[S[,RS[S[,RR/#)rP transaction shard_hintrSClusterPipeline)rrrUrWrMrXrY<s-%%#C=%=Ec]% %rLc sdV'd \R4hV'd \R4h\V4#)z Create & return a new :class:`~.ClusterPipeline` object. Cluster implementation of pipeline does not support transaction or shard_hint. :raises RedisClusterException: if transaction or shard_hint are truthy values z(shard_hint is deprecated in cluster modez)transaction is deprecated in cluster mode)r6r2)rr0r1rrMpipelineZRedisCluster.pipeline<s- '(RS S '(ST Tt$$rLcs<V^8dQhRS[RS[S[,RS[RS[RS[S[,RS[S[S[,,RS[RS[/#) rPrtimeoutr.blockingblocking_timeout lock_class thread_localrS)r=rrrr rrUrWrMrXrYNsvH H H %H  H  H #5/ H T$Z(H H  H rLc  s4Vf\pV!VVVVVVVR7#)a Return a new Lock object using key ``name`` that mimics the behavior of threading.Lock. If specified, ``timeout`` indicates a maximum life for the lock. By default, it will remain locked until release() is called. ``sleep`` indicates the amount of time to sleep per loop iteration when the lock is in blocking mode and another client is currently holding the lock. ``blocking`` indicates whether calling ``acquire`` should block until the lock has been acquired or to fail immediately, causing ``acquire`` to return False and the lock not being acquired. Defaults to True. Note this value can be overridden by passing a ``blocking`` argument to ``acquire``. ``blocking_timeout`` indicates the maximum amount of time in seconds to spend trying to acquire the lock. A value of ``None`` indicates continue trying forever. ``blocking_timeout`` can be specified as a float or integer, both representing the number of seconds to wait. ``lock_class`` forces the specified lock implementation. Note that as of redis-py 3.0, the only lock class we implement is ``Lock`` (which is a Lua-based lock). So, it's unlikely you'll need this parameter, unless you have created your own custom lock class. ``thread_local`` indicates whether the lock token is placed in thread-local storage. By default, the token is placed in thread local storage so that a thread only sees its token, not a token set by another thread. Consider the following timeline: time: 0, thread-1 acquires `my-lock`, with a timeout of 5 seconds. thread-1 sets the token to "abc" time: 1, thread-2 blocks trying to acquire `my-lock` using the Lock instance. time: 5, thread-1 has not yet completed. redis expires the lock key. time: 5, thread-2 acquired `my-lock` now that it's available. thread-2 sets the token to "xyz" time: 6, thread-1 finishes its work and calls release(). if the token is *not* stored in thread local storage, then thread-1 would see the token value as "xyz" and would be able to successfully release the thread-2's lock. In some use cases it's necessary to disable thread local storage. For example, if you have code where one thread acquires a lock and passes that lock instance to a worker thread to release later. If thread local storage isn't disabled in this case, the worker thread won't see the token set by the thread that acquired the lock. Our assumption is that these cases aren't common and as such default to using thread local storage.)r4r.r5r6r8r)rrr4r.r5r6r7r8s&&&&&&&&rMlockZRedisCluster.lockNs2|  J  -%  rL)rrrfrrrgrrrrrdrrerrry)rrrfrrrgrrrrrdrrerrNNNF)NN)Ng?TNNT)0rGrHrIrJ__doc__Z classmethodr_ __slots__r@rrrr>rrrrrwarningswarnrget_running_looprrrrrrrrrrrrrrrrr r rrr)rr3r9rK__classdictcell__rV@rMrNrN]s+Qf@I(# $7;&*#("#,-/0$"<@"&"&%)",%4%6'!&'(26!&NR*.#':>&*%)'&*#(%)48%)"#PTYe2e2N& E E1GgVW''--2L]],,   = ===DDDDLL// / /BB$$822&&##44  CG   D11fQQ(RRhF-F-P%%$H H H rLrNcsa]tRtRtoRtRtRRRR]/V3RlRllltV3RlR ltV3R lR lt R t ] P] P3V3R lRlltV3RlRltV3RlRltV3RlRltV3RlRltV3RlRltRtVtR#)rDiz Create a new ClusterNode. Each ClusterNode manages multiple :class:`~redis.asyncio.connection.Connection` objects for the (host, port). rZrhNcsx<V^8dQhRS[RS[S[S[3,RS[S[,RS[RS[S[,RS[RR/#) rPr`ra server_typerhrZrrSN)rTr rrr rrrUrWrMrXClusterNode.__annotate__skWWWCHoWc] W  Wz*W!W WrLc s@VR8Xd\P!V4pWR&W&R&WnW n\ W4VnW0nW@nWPnW`n VPR/4Vn .Vn \P!VPR7VnR#) localhostr`rar)ZmaxlenN)socket gethostbynamer`rar%rrErhrZrr]rr collectionsZdeque_free)rr`rarErhrZrs&&&&$$,rMrZClusterNode.__init__s ; ''-D$(&!$(&!  !$- &. 0!2"3"7"78Lb"Q.0(3(9(9AUAU(V rLcrrrTrUrWrMrXrFs  # rLc spRVP RVP RVP RVP R2 #)z[host=z, port=z, name=z, server_type=Z])r`rarrErrrM__repr__ZClusterNode.__repr__s?TYYKwtyyk2II;nT-=-=,>a A rLcr)rPobjrSrrUrWrMrXrFsFF#F$FrLcsd\V\4;'dVPVP8H#r)rrDr)rrNrrM__eq__ZClusterNode.__eq__s$#{+EEDII0EErLzUnclosed ClusterNode objectcrrrrUrWrMrXrFs)  rLcsVPF^pVP'gKV!VP RV: 2\VR7RVRVP/pV!4P V4R# R# \ dLi;i)rrrrN)rZ is_connectedrrrr)rrrrr&&& rMrZClusterNode.__del__s ++J&&&**+1TH5tT'y$:K:KLGF11':,$s&A11 A?>A?crrrFrUrWrMrXrFs  $ rLcs"\P!RVP4RR/GRjxL p\RV4R4pV'dVhR#L#5i)c3j"TF)p\P!VP44xK+ R#5irrr disconnect)rr& rMr )ClusterNode.disconnect..s."3J##J$9$9$;<<"313Zreturn_exceptionsTNc3sV"TFp\V\4'gKVxK! R#5ir)rr)rrrTrMr rUsE3C*S)*DCC3s) ))rr#rZnext)rr'Zexcs& rMrSZClusterNode.disconnects[NN"&"3"3 #   E3EtL I  s+AA$AcrrrrUrWrMrXrFs ( (J (rLcs(VPP4# \dk\TP4TP 8d<TP !R/TPBpTPPT4Tu#\4hi;i)NrF) rKZpopleft IndexErrorrrrhrZrrr4rrTrMacquire_connectionZClusterNode.acquire_connections~ (::%%' ' (4$$%(<(<<!22LT5K5KL !!((4!!%' '  (sA(B Bcs2<V^8dQhRS[RS[RS[RS[/#)rPrrrRrS)rrTrrUrWrMrXrFs-$/2>A rLcs"\V9d1VPRR7GRjxL pVP\4MVP4GRjxL p\V9dVP\4VPRR4W P 9dVP V,!V3/VB#V#LLe \d\T9dT\,u#hi;i5i)T)Zdisable_decodingNr)rrr]r7rr)rrrrRZresponses&&&, rMparse_responseZClusterNode.parse_responses v%!+!9!94!9!PP <(!+!9!9!;; V # JJ~ &  64  -- -**73HGG G'Q< 'n--  sUC$ B:B6B:C$B:B8B:AC$6B:8B::#C!C$C!!C$cs,<V^8dQhRS[RS[RS[/#rrrUrWrMrXrFs" * *3 *# *# *rLcs>"VP4pVPVP!V!R4GRjxL VP!W1^,3/VBGRjxL VPP V4#LBL! TPP T4i;i5i)FN)rXsend_packed_commandZ pack_commandrYrKr)rr rRrs&*, rMr)ZClusterNode.execute_commands,,. ,,Z-D-Dd-KUSSS *,,ZaKFKK JJ  j ) TL JJ  j )s84BA9BA=A;A=B;A==BBcs4<V^8dQhRS[R,RS[/#)rPcommandsPipelineCommandrS)rrrUrWrMrXrF$s!t4E/F4rLcs"VP4pVPVPRV44R4GRjxL RpVF?pVP!W$P^,3/VP BGRjxL VnKA VPPV4V#LhL, \dpYTnRpRp?K}Rp?ii;i5i)c3s8"TFqPxK R#5ir)r )rrrTrMr Z/ClusterNode.execute_pipeline..*s$B#XXsFNT) rXrZZ pack_commandsrYr rRresultrrKr)rr[rr'rr(s&& rMexecute_pipelineZClusterNode.execute_pipeline$s,,. ,,  $ $$B$B BE   C #'#6#6 $/2zz$  *% %    sKC C  C ) rrKrZrr`rhrrarrErr:)rGrHrIrJr=r>rrrMrOrr?r@rrArrSrXrYr)r^rKrBrCrDrMrDrDs IW % W.8WW8  FF1L]],,   ( (4 * *rLcsa]tRtRtoRtRV3RlRlltRV3RlRlltRV3RlRlltV3R lR ltRV3R lR llt V3R lRlt V3RlRlt RV3RlRllt V3RlRlt RtVtR#)ri>Nc s<V^8dQhRS[R,RS[RS[S[S[3,RS[S[S[S[S[3,.S[S[S[3,3,,RR/#)rPrbrDrcrrrSN) rrrrTrrrr rrUrWrMrXNodesManager.__annotate__Ksl11M*1 $1 S> 1  %S/):E#s(O)K LM 1  1rLcsVUu/uFqUPVbK upVnW nW0nW@nRVn/Vn/Vn\4Vn RVn R#uupir) rrbrcrrrrrr#read_load_balancerr/)rrbrcrrrs&&&&& rMrZNodesManager.__init__Ksd;HH-$iio-H%:"!2*+/57;="..,0IsA!c rrrrUrWrMrXr_]sDsmsmC=  - rLcsV'dKV'dCVR8Xd\P!V4pVPP\ WR74#V'dVPPV4#\ R4h)rGr-zEget_node requires one of the following: 1. node name 2. host and port)rHrIrrr%r2rrrMrZNodesManager.get_node]si D{"++D1##'' 4(KL L ##'' 2 2# rLcsX<V^8dQhRS[S[R3,RS[S[R3,RS[RR/#)rPoldrDnew remove_oldrSN)rrTrrUrWrMrXr_qsG #}$ %#}$ %   rLcsV'd\\VP44F>pWB9gK \P!VP V4P 44pK@ VP 4FGwrFWA9d9W,VJdK\P!W,P 44pWaV&KI R#r)rrrrr]rSitems)rrarbrcrZtaskrs&&&& rM set_nodesZNodesManager.set_nodesqs SXXZ(?"..swwt}/G/G/IJD)))+JD{9$**39+?+?+ABI &rLcrrrFrUrWrMrXr_s$%$%T$%rLcsnVPpVPVPVPR7pV'd"VP\ 8wd \ VnMX\ VPVP\ 3/VPBpVPVPVPV/4W PVP,9dVPVP,^,p\VnVPVP,PV4VPVP,PV4W PVP,^&VP V8XdW nMV.VPVP&RVnR#)r-N)r/rr`rarErrDrrerrrZslot_idr rZremover)rr(Zredirected_nodeZ old_primarys& rM_update_moved_slotsZ NodesManager._update_moved_slotssN  ! !--QVV!&&-A **g5.5+*+/+A+AO NN4++o.B.BO-T U ..qyy9 9**1995a8K'.K #   QYY ' . .{ ;   QYY ' . . ?-<  QYY ' *  K/$3! ,;*;D  QYY ' $rLcrO)rPrrdrSrD)rrrUrWrMrXr_s%-1 rLcsVP'dVP4V'duVPV,^,PpVPP V\ VPV,44pVPV,V,#VPV,^,# \\3d\RT RTP R24hi;i)rrz5" not covered by the cluster. "require_full_coverage=Z") r/rfrrr`Zget_server_indexrrWrr8rc)rrrdZ primary_namerrPrMr ZNodesManager.get_node_from_slots   $ $ & !#//5a8== 22CC #d&6&6t&<"=''-h77##D)!, ,I& %**.*D*D)EQH  sB:A3B: B::.C(cr)rPrErSrD)rTrrUrWrMrXr_s   C D>crrrFrUrWrMrXr_s~%~%$~%rLc s"VPP4/p/p.pRpRpRpVPP4EFpVP R4GRjxL pRp\T4^8XdUT^,^,^,'g8\TP4^8XdTPT^,^,^&TEFLp \^\T 44F&p Y,U u.uFp \T 4NK up Y&K( T ^,p T ^,pTR8Xd TPp\T ^,4pTPY4wr.pTP\Y44pT'g\!Y\"3/TP$BpTTTP&&TP)T4T R,pTFpT^,pT^,pTPY4wrTP\Y44pT'g\!Y\*3/TP$BpTTTP&&TP)T4K \\T ^,4\T ^,4^,4Fp Y9dTY+&KY+,^,pTP&TP&8wgK;TP)TP& RTP& RT 24\T4^8gKz\ R R P-T4 24h EKO Rp\\.4F p Y9gK RpM T'gEKM V'g\ R \1V4 24VhV'g2VP2'd \ R \V4 R \. R24hW nVP7VP8VRR7VP7VPVP8RR7VP;\"4^,VnRVnR#EL \ d \ R4hi;i \dp T pRp ? EK Rp ? ii;iuup i5i)FNrz(Cluster mode is not enabled on this nodeTZ:rNNz vs z on slot: z6startup_nodes could not agree on a valid slots cache: z, zORedis Cluster cannot be connected. Please provide at least one reachable node: z9All slots are not covered after query all startup_nodes. z of z covered...)rc) r`Zresetrbrr)r7r6rrr`r!rBrremap_host_portrr%rDrrrrr joinr)rTrcrrerrrr/)rZtmp_nodes_cacheZ tmp_slotsZ disagreementsZstartup_nodes_reachableZ fully_covered exceptionZ startup_nodeZ cluster_slotsr(rZiZvalZ primary_noder`raZnodes_for_slotr*Z replica_nodesZ replica_nodeZtarget_replica_nodeZtmp_slots& rMrZNodesManager.initializes. %%'4646  "'   ..557L *6*F*F*W$WM +/'M"a'%a(+A..**+q0)5):): a #A&%q#d),A<@GDGS|C0GDDG-#Aw #A2:',,D<?+!11$= !#-11-2KL ""-G#/3/E/E#K5@ 0 01%%k2 $R $1L'?D'?D!%!5!5d!AJD*9*=*=mD>W*X'..9 /373I3I/+ATO$7$<$<="))*=>%2s47|Sa\A-=>A)'5 $-<?#==K,<,<<)00#+==/k6F6F5GzRSQT U #=1A5&;'448IIm4L3M%O'"!"?I&n!M34%$)M5}w8z''''*9~&68  !;!;!;(Ky>"$'?&@A % t''TJ t))4+;+;M!99'B1E $e%X$/B     ,EsAQ PPP"P8$,QAQ0Q F/Q8:Q7;Q7 Q QQ4QBQPP55P88 QQ Q QQcr)rPattrrSNrLrUrWrMrXr_Es    rLcs"RVn\P!R\W4P 44!GRjxL R#L5i)Nc3rQrrRrrrTrMr Z&NodesManager.aclose..Hs,8D##DOO$5668rV)rrr#Zgetattrr)rrjrrMrZNodesManager.acloseEs> nn#D/668   s=AAAcsB<V^8dQhRS[RS[RS[S[S[3,/#)rPr`rarS)rTrr rUrWrMrXr_Ns*CsuS#XrLc sPVP'dVPW34#W3#)z Remap the host and port returned from the cluster to a different internal value. Useful if the client is not connecting directly to the cluster. r)rr`rarrMrgZNodesManager.remap_host_portNs+    %%tl3 3zrL) r/rrrrr`rcrrb) r/rrrr`rcrrbrrr;r<)r)rGrHrIrJr>rrrerfr rrrrgrKrBrCrDrMrr>sj I11$($$%$%L*  ~%~%@  rLrcs,a]tRtRtoRtR!tV3RlRltV3RlRltV3RlRltV3R lR lt V3R lR lt V3R lRlt V3RlRlt V3RlRlt V3RlRltV3RlRltR"V3RlRlltR"V3RlRlltV3RlRltV3RlRltRtVtR #)#r2iYaG Create a new ClusterPipeline object. Usage:: result = await ( rc.pipeline() .set("A", 1) .get("A") .hset("K", "F", "V") .hgetall("K") .mset_nonatomic({"A": 2, "B": 3}) .get("A") .get("B") .delete("A", "B", "K") .execute() ) # result = [True, "1", 1, {"F": "V"}, True, True, "2", "3", 1, 1, 1] Note: For commands `DELETE`, `EXISTS`, `TOUCH`, `UNLINK`, `mset_nonatomic`, which are split across multiple nodes, you'll get multiple results for them in the array. Retryable errors: - :class:`~.ClusterDownError` - :class:`~.ConnectionError` - :class:`~.TimeoutError` Redirection errors: - :class:`~.TryAgainError` - :class:`~.MovedError` - :class:`~.AskError` :param client: | Existing :class:`~.RedisCluster` client cr)rPrrSN)rNrUrWrMrXClusterPipeline.__annotate__s::|::rLcs Wn.VnR#r_client_command_stack)rrrrMrZClusterPipeline.__init__s 79rLcrrPrSr2rFrUrWrMrXrls"3rLcs"VPP'd#VPP4GRjxL .VnV#L 5ir)rnrrrorrrMrZClusterPipeline.initializes= << # # #,,))+ + +   ,s:A A A crrprFrUrWrMrXrls''"3'rLcrrrrrrMrZClusterPipeline.__aenter__rrcrrrFrUrWrMrXrls*!!!!$!SW!rLcs".VnR#5irrorrrMrZClusterPipeline.__aexit__s  s cr)rPrSNr2rrUrWrMrXrls!--9S$0A%AB-rLcrrrrrrMrZClusterPipeline.__await__rrLcrrprFrUrWrMrXrls,rLcs.VnV#rrqrrrM __enter__ZClusterPipeline.__enter__s  rLcrrrFrUrWrMrXrls)!!!$!4!D!rLcs.VnR#rrqrrrM__exit__ZClusterPipeline.__exit__s  rLcrr)rrUrWrMrXrls$rLc sR#)z?Pipeline instances should always evaluate to True on Python 3+TrFrrrM__bool__ZClusterPipeline.__bool__srLcrr)rrUrWrMrXrls(((rLcs,\VP4#r)rrorrrM__len__ZClusterPipeline.__len__s4&&''rLcs@<V^8dQhRS[S[S[3,RS[RR/#)rPr rRrSr2r+rUrWrMrXrls/4+,8; rLc s|VPP\\VP4.VO5/VB4V#)a$ Append a raw command to the pipeline. :param args: | Raw command args :param kwargs: - target_nodes: :attr:`NODE_FLAGS` or :class:`~.ClusterNode` or List[:class:`~.ClusterNode`] or Dict[Any, :class:`~.ClusterNode`] - Rest of the kwargs are passed to the Redis connection )rorr\r)rr rRs&*,rMr)ZClusterPipeline.execute_commands< "" C 3 34 Ft Fv F  rLcs<<V^8dQhRS[RS[RS[S[,/#)rPraise_on_errorallow_redirectionsrS)rrrrUrWrMrXrls).%.%".%?C.% c.%rLc s"VP'g.#\VPP4FzpVPP'd#VPP 4GRjxL VP VPVPVVR7GRjxL u.Vn# XhLCL \dup\T4TPP9dKTpTPP4GRjxL \P!R4GRjxL Rp?KhRp?ii;i .Tni;i5i)a Execute the pipeline. It will retry the commands as specified by :attr:`cluster_error_retry_attempts` & then raise an exception. :param raise_on_error: | Raise the first error if there are any errors :param allow_redirections: | Whether to retry each failed command individually in case of redirection errors :raises RedisClusterException: if target_nodes is not provided & the command can't be mapped to a slot N)rvrwr,)ror!rnrfrr_executerrrr$rrr.)rrvrwr&r(rirrMexecuteZClusterPipeline.executes$"""I %4<<DDE<<+++,,11333!% ++'5+= "/"&#%D 1F,O)4 %Aw$.."C"CC$% "ll11333%mmD111#%D sE AD=3B74D=9,B;%B9&B;)D=+E 3D=9B;; D:AD5 D  D5(D+)D5.D=4D55D::D== EE c sT<V^8dQhRRRS[R,RS[RS[RS[S[,/#)rPrrNstackr\rvrwrS)rrrrUrWrMrXrlsNK-K-K-%&K- K- ! K- c K-rLcs "VUu.uF8qUP'd#\VP\4'gK6VNK: pp/pVEFpVPP RR4pV'd*VP V4'gVP V4p MEVP!VPRV/GRjxL p V 'g\RVP R24h\V 4^8d\RVP 24hV ^,p V PV9dV .3WzP&WzP,^,PV4EK \P!RVP44!GRjxL p \!V 4'EdV'dkVFdp\VP\"\$\&34'gK0VP(!VP/VPBGRjxL VnKf V'dVFpVPp \V \4'gK'RP+\-\.VP44pRVP0^, R V R V P 2pV3V PR ,,V nV h VP3VP54P4pVeQV^,FCp\7VP4VP8P:9gK3VP=4M VUu.uFqUPNK up#uupiELELELU \dp YnRp ? EKRp ? ii;iuupi5i) rNr rrzToo many targets for command c3s"TF8p\P!V^,PV^,44xK: R#5i)rN)rrr^rkrTrMr Z+ClusterPipeline._execute..s8*D##DG$<$&J&J%99.I %+%<%<XX&)7&  $/;CHH:[Q< 1$+.KCHH:,VWW?Dyy%$(":ii )) Q  & &s +#&~~!LLN   v;;!C!#**}j(.STT+/5/E/E!$0-0ZZ0*CJ C ZZF!&)44"%((3x+B"C()9(:"WIF--3[[M;(+fv{{2&> $  !99V%<%<%>%C%CDL' (??CCJJ'4>>+L+LL335 +',,es e,,I   * )+)*JJ+8-sN3MMAN 1N;M< NCN M N+-N)MM M N$NCN"N:M? NNM M<*M70N7M<<NcrO)rPrrrSr2)rTr=rUrWrMrXrl2s%#' rLcsVPPV4P4FpVP!V.VO5!K V#r)rnZ_partition_keys_by_slotrr))rrrZ slot_keyss&&* rM_split_command_across_slotsZ+ClusterPipeline._split_command_across_slots2sA==dCJJLI   59 5M rLcs:<V^8dQhRS[S[S[3,RR/#)rPmappingrSr2)rr;r<rUrWrMrXrl:s'  w 23   rLcs>VPPp/pVP4FEp\VP V^,44pVP V.4P V4KG VP4FpVP!R.VO5!K V#)rZMSET) rnrrdr*rZ setdefaultZextendrr))rr~rZ slots_pairsZpairrZpairss&& rMmset_nonatomicZClusterPipeline.mset_nonatomic:s,,&& MMODGNN4734D  " "4 , 3 3D 9$!'')E   0% 0* rLrmN)rorn)TT)rGrHrIrJr=r>rrrrrrrrsrtrur)ryrxr}rrKrBrCrDrMr2r2Ys"H.I::  ''!!--!!((&.%.%`K-K-Z  rLr2rr&rcsDa]tRtRtoV3RlRltV3RlRltRtVtR#)r\iRcs0<V^8dQhRS[RS[RS[RR/#)rPr|r rRrSN)rrrUrWrMrXPipelineCommand.__annotate__Ss)222S2C2D2rLcs8W nW0nWnRVnR#rr rRr|r])rr|r rRs&&*,rMrZPipelineCommand.__init__Ss   -1 rLcrrrLrUrWrMrXrYs@@#@rLcsVRVP RVP RVP R2#)Z[z] r{Z))r|r rRrrrMrMZPipelineCommand.__repr__Ys)4==/DII;b Q??rLrN)rGrHrIrJrrMrKrBrCrDrMr\r\Rs22 @@rLr\)crrJrrHr[r?Ztypingrrrrrrrrr r r r Zredis._parsersr rZredis._parsers.helpersrrrZredis.asyncio.clientrZredis.asyncio.connectionrrrrZredis.asyncio.lockrZredis.asyncio.retryrZ redis.backoffrZ redis.clientrrrZ redis.clusterrrr r!r"r#r$r%r&Zredis.commandsr'r(Z redis.crcr)r*Zredis.credentialsr+Zredis.exceptionsr,r-r.r/r0r1r2r3r4r5r6r7r8r9r:Z redis.typingr;r<r=Z redis.utilsr>r?r@rArBrTrCrErNrDrr2rZreplaceZlowerZsetattrr\rFrLrMrs_     8 3XX#%)DD   D80"32C](;T#}BT=U M y  ="68Qy  xbbJXXvnm%9;Tnb)Gooc3'--/G"" OW&