AHjUddlmZddlZddlZddlmZddlmZddlm Z m Z m Z m Z m Z ddlmZe Gdd e ZGd d ZeZGd d ZeedZded<dddZy)) annotationsN)Callable)partial)AnyClassVarProtocolcastruntime_checkable)import_attributeceZdZddZddZy) SerializercyN)selfobjs F/root/tools/cai/cai_env/lib/python3.12/site-packages/rq/serializers.pydumpszSerializer.dumpscyrr)rdatas rloadszSerializer.loadsrrN)rrreturnbytes)rrrr)__name__ __module__ __qualname__rrrrrrr s./rrcveZdZUeej ej Zded<ejZded<y)DefaultSerializer)protocolz ClassVar[Callable[[Any], bytes]]rz ClassVar[Callable[[bytes], Any]]rN) rrrrpicklerHIGHEST_PROTOCOL__annotations__rrrrr!r!s-.5fllVMdMd.eE +e.4llE +:rr!c,eZdZedZedZy)JSONSerializercJtj|i|jdSNzutf-8)jsonrencode)argskwargss rrzJSONSerializer.dumpss!zz4*6*11'::rcRtj|jdg|i|Sr))r*rdecode)sr,r-s rrzJSONSerializer.loads s$zz!((7+=d=f==rN)rrr staticmethodrrrrrr'r's(;;>>rr')r*r#zdict[str, Serializer]SERIALIZER_ALIASESc|stSt|tr2|}tj |}|st t t|}t|t s td|S)aThis function checks the user defined serializer for ('dumps', 'loads') methods It returns a default pickle serializer if not found else it returns a MySerializer The returned serializer objects implement ('dumps', 'loads') methods Also accepts a string path to serializer that will be loaded as the serializer. Args: serializer (Callable): The serializer to resolve. Returns: serializer (Callable): An object that implements the SerializerProtocol z.Serializer should have (dumps, loads) methods.) PickleSerializer isinstancestrr2getr rr NotImplementedError) serializerserializer_paths rresolve_serializerr;+s] *c"$'++O< j*:?*KLJ j* -!"RSS rr)r9zSerializer | str | Nonerr) __future__rr*r#collections.abcr functoolsrtypingrrrr r utilsr rr!r4r'r2r%r;rrrrAsq" $CC#000 ;; %>> -) r