k7iSSKJr SSKJrJrJrJrJr SSKJ r J r SSK J r SSK JrJr SSKJr SSKJr SSKJr \"S \\\-S 9r"S S \\5rg ))Sequence)AnyGeneric SupportsFloatTypeVar get_origin)DeserializationErrorSerializationError) bear_spray) BaseModelValidationError) TypeAdapter)PydanticSerializationError) AsyncKeyValueT)boundc @\rSrSrSr\SS\S\\S\ S-S\ SS4 S jj5r S \ \ \ 4S\S-4S jrS \S\ \ \ 44S jrSS .S\ S\ S-S\S-4SjjrSS .S\\ S\ S-S\\S-4SjjrSSS.S\ S \S\ S-S\S-SS4 SjjrSSS.S\\ S\\S\ S-S\\S-S-SS4 SjjrSS .S\ S\ S-S\ 4SjjrSS .S\\ S\ S-S\4SjjrSS .S\ S\ S-S\\S-\S-44SjjrSS .S\\ S\ S-S\\\S-\S-44SjjrSrg)PydanticAdapterz^Adapter around a KVStore-compliant Store that allows type-safe persistence of Pydantic models.N key_valuepydantic_modeldefault_collectionraise_on_validation_errorreturncXl[U5nUSL=(a [U[5Ul[ [ "U5UlX0lX@l g)a Create a new PydanticAdapter. Args: key_value: The KVStore to use. pydantic_model: The Pydantic model to use. default_collection: The default collection to use. raise_on_validation_error: Whether to raise a ValidationError if the model is invalid. N) _key_valuer issubclassr_is_list_modelrr _type_adapter_default_collection_raise_on_validation_error)selfrrrrorigins a/home/james-whalen/.local/lib/python3.13/site-packages/key_value/aio/adapters/pydantic/adapter.py__init__PydanticAdapter.__init__sI"*3N+$*$$6$W:fh;W(^N;/A 0I'valuec$UR(a+URRURS/55$URRU5$![a,nUR (aSU3n[ U5UeSnAgSnAff=f)NitemsInvalid Pydantic model: )rrvalidate_pythongetr r!r r"r(emsgs r$_validate_modelPydanticAdapter._validate_model.s~ ""))99%))GR:PQQ%%55e< < ..08*3/Q6  s;AA B#"B  BcUR(aSURRUSS90$URRUSS9$![anSU3n[ U5UeSnAff=f)Nr*json)moder+)rr dump_pythonrr r.s r$_serialize_model PydanticAdapter._serialize_model:sv 1""!3!3!?!?F!?!STT%%11%f1E E) 1,QC0C$S)q 0 1s,A A A)A$$A)) collectionkeyr9c# U=(d URnURRXS9IShvN =n(aURUS9$gN7f)aGet and validate a model by key. Returns: The parsed model instance, or None if not present. Raises: DeserializationError if the stored data cannot be validated as the model and the PydanticAdapter is configured to raise on validation error. r:r9Nr()r rr-r1)r"r:r9r(s r$r-PydanticAdapter.getDsT ;4#;#; //--#-MM M5 M''e'4 4Ns2AAAkeysc# U=(d URnURRXS9IShvN nUVs/sHoD(aURUS9OSPM sn$N,s snf7f)aBatch get and validate models by keys, preserving order. Returns: A list of parsed model instances, or None if missing. Raises: DeserializationError if the stored data cannot be validated as the model and the PydanticAdapter is configured to raise on validation error. r?r9Nr=)r rget_manyr1)r"r?r9valuesr(s r$rBPydanticAdapter.get_manyUsg ;4#;#; 48OO4L4LRV4L4n.nRXYRXU$$5$1DRXYY/oYs 2A(A!A(!A#A(#A()r9ttlrEc# U=(d URnURUS9nURRXX4S9IShvN gN7f)z_Serialize and store a model. Propagates SerializationError if the model cannot be serialized. r=)r:r(r9rEN)r r7rput)r"r:r(r9rE value_dicts r$rGPydanticAdapter.putesG  ;4#;#; %)%:%:%:%G oo!!c !\\\sAA A A rCc# U=(d URnUVs/sHoPRUS9PM nnURRXX4S9IShvN gs snfN 7f)zJSerialize and store multiple models, preserving order alignment with keys.r=)r?rCr9rEN)r r7rput_many)r"r?rCr9rEr( value_dictss r$rKPydanticAdapter.put_manypsa ;4#;#; ]c,d]cTY-B-B-B-O]c ,doo&&DQ[&eee-eesA AA A A cz# U=(d URnURRXS9IShvN $N7f)zGDelete a model by key. Returns True if a value was deleted, else False.r<N)r rdelete)r"r:r9s r$rOPydanticAdapter.deletezs3;4#;#; __+++KKKK 2;9;cz# U=(d URnURRXS9IShvN $N7f)zDDelete multiple models by key. Returns the count of deleted entries.rAN)r r delete_many)r"r?r9s r$rSPydanticAdapter.delete_manys3;4#;#; __00d0RRRRrQc# U=(d URnURRXS9IShvN up4UcgURUS9=n(aXT4$gN$7f)zfGet a model and its TTL seconds if present. Returns (model, ttl_seconds) or (None, None) if missing. r<N)NNr=)r rrEr1)r"r:r9entryttl_infovalidated_models r$rEPydanticAdapter.ttlsh  ;4#;#; !% 3 3 3 SS ="222? ?? ?#. .Ts2AA%Ac# U=(d URnURRXS9IShvN nUVVs/sHupEU(aURUS9OSU4PM! snn$N3s snnf7f)zKBatch get models with TTLs. Each element is (model|None, ttl_seconds|None).rANr=)r rttl_manyr1)r"r?r9entriesrVrWs r$r[PydanticAdapter.ttl_manyst;4#;#; JN//JbJbhlJbKEEEhophoUdUZe%%E%2xPhoppEEps 2A0A( A0&A*$A0*A0)r rrr!r)NF)__name__ __module__ __qualname____firstlineno____doc__r rtyperstrboolr%dictrr1r7r-listrBrrGrrKrOintrStuplefloatrEr[__static_attributes__r'r$rrsh *.*/ J JQJ $J J $( J  JJ2 T#s(^ D 1a1DcN1?CStq4x"KOZ49ZS4ZZSWXY\`X`SaZ IMjn ]S ] ]3: ]S`cgSg ]sw ]QUDHfIf'/{fCF:f[cdqtxdx[y}A\Af fBFLLC$JL$L NRSd3iSd SVYS ?CStuQQUXW\_cWcMcGd(KOq49qS4ZqSWX]^_bf^fhmptht^tXuSvqqr'rN)collections.abcrtypingrrrrrkey_value.shared.errorsr r )key_value.shared.type_checking.bear_sprayr pydanticr r pydantic.type_adapterr pydantic_corer!key_value.aio.protocols.key_valuerrrrlr'r$rusJ$CCL@/-4; Cy8I#667QqgajQqr'