o i@sTddlmZddlmZmZddlmZddlmZddl m Z Gddde Z dS) )Sequence)Any SupportsFloat)override) AsyncKeyValue) BaseWrapperc seZdZdZefdfdededeeedfdedd f fd d Z e d d d e de d Bde e e fd BfddZe d d dee de d Bdee e e fd BfddZe d d d e de d Bdee e e fd Bed BffddZe d d dee de d Bdeee e e fd Bed BffddZe d d dd e de e e fde d Bded Bdd f ddZe d d ddee dee e e fde d Bdeed Bd Bdd f ddZe d d d e de d Bdefd d!Ze d d dee de d Bdefd"d#ZZS)$FallbackWrapperaBWrapper that falls back to a secondary store when the primary store fails. This wrapper attempts operations on the primary store first. If the operation fails with one of the specified exceptions, it automatically falls back to the secondary store. This provides high availability and graceful degradation when the primary store is unavailable. Note: This wrapper only provides read fallback by default. Writes always go to the primary store. For write fallback, consider using write_to_fallback=True, but be aware of potential consistency issues. Fprimary_key_valuefallback_key_value fallback_on.write_to_fallbackreturnNcs&||_||_||_||_tdS)aInitialize the fallback wrapper. Args: primary_key_value: The primary store to use. fallback_key_value: The fallback store to use when primary fails. fallback_on: Tuple of exception types that trigger fallback. Defaults to (Exception,). write_to_fallback: If True, write operations also fall back to secondary store. If False (default), write operations only go to primary. N)r r r r super__init__)selfr r r r  __class__m/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/key_value/aio/wrappers/fallback/wrapper.pyrs zFallbackWrapper.__init__) collectionkeyrcFz |jj||dIdHWS|jy"|jj||dIdHYSwN)rr)r getr r rrrrrrr- zFallbackWrapper.getkeyscrN)rr)r get_manyr r rrrrrrr4rzFallbackWrapper.get_manycrr)r ttlr r rrrrr ;rzFallbackWrapper.ttlcrr)r ttl_manyr r rrrrr!BrzFallbackWrapper.ttl_many)rr valuer c n|jr*z|jj||||dIdHWS|jy)|jj||||dIdHYSw|jj||||dIdHS)N)rr"rr )r r putr r )rrr"rr rrrr$IszFallbackWrapper.putvaluesc r#)N)rr%rr )r r put_manyr r )rrr%rr rrrr&Ss zFallbackWrapper.put_manycb|jr&z |jj||dIdHWS|jy%|jj||dIdHYSw|jj||dIdHSr)r r deleter r rrrrr(dzFallbackWrapper.deletecr'r)r r delete_manyr r rrrrr*nr)zFallbackWrapper.delete_many)__name__ __module__ __qualname____doc__ Exceptionrtupletypeboolrrstrdictrrlistrfloatr r!rr$rr&r(intr* __classcell__rrrrr sV.6:B8  " .rN) collections.abcrtypingrrtyping_extensionsr!key_value.aio.protocols.key_valuerkey_value.aio.wrappers.baserrrrrrs