i\SSKJr SSKrSSKrSSKrSSKJrJr SSKJ r SSK J r SSK J r Jr "SS \5r"S S \5r"S S \5r\rg)) annotationsN)ABCabstractmethod)Any) BaseModel)get_qualified_name!import_module_from_qualified_namec@\rSrSrSr\SSj5r\SSj5rSrg) BaseSerializeran Interface for value serialization used by the workflow context and state store. Implementations must encode arbitrary Python values into a string and be able to reconstruct the original values from that string. See Also: - [JsonSerializer][workflows.context.serializers.JsonSerializer] - [PickleSerializer][workflows.context.serializers.PickleSerializer] cgNselfvalues W/home/james-whalen/.local/lib/python3.13/site-packages/workflows/context/serializers.py serializeBaseSerializer.serializes,/cgrrrs r deserializeBaseSerializer.deserialize s.1rrNrrreturnstrrrrr) __name__ __module__ __qualname____firstlineno____doc__rrr__static_attributes__rrrr r s% //11rr c@\rSrSrSrS SjrS SjrS SjrS SjrSr g) JsonSerializer$aF JSON-first serializer that understands Pydantic models and LlamaIndex components. Behavior: - Pydantic models are encoded as JSON with their qualified class name so they can be faithfully reconstructed. - LlamaIndex components (objects exposing `class_name` and `to_dict`) are serialized to their dict form alongside the qualified class name. - Dicts and lists are handled recursively. Fallback for unsupported objects is to attempt JSON encoding directly; if it fails, a `ValueError` is raised. Examples: ```python s = JsonSerializer() payload = s.serialize({"x": 1, "y": [2, 3]}) data = s.deserialize(payload) assert data == {"x": 1, "y": [2, 3]} ``` See Also: - [BaseSerializer][workflows.context.serializers.BaseSerializer] - [PickleSerializer][workflows.context.serializers.PickleSerializer] c[US5(aSUR5[U5S.nU$[U[5(aSUR SS9[U5S.$[U[ 5(a4UR5VVs0sHup4X0RU5_M snn$[U[5(a!UVs/sHoPRU5PM sn$U$s snnfs snf)a" Events with a wrapper type that includes type metadata, so that they can be reserialized into the original Event type. Traverses dicts and lists recursively. Args: value (Any): The value to serialize. Returns: Any: The serialized value. A dict, list, string, number, or boolean. class_nameT)__is_componentrqualified_namejson)mode) __is_pydanticrr+) hasattrto_dictr isinstancer model_dumpdictitemsserialize_valuelist)rrretvalkvitems rr5JsonSerializer.serialize_value?s 5, ' '"&"4U";F M eY ' '!%))v)6"4U";  eT " ";@;;=I=41A++A..=I I eT " ";@A54((.5A A JBs C#C)cURU5n[R"U5$![a [ S[ U5SU<35ef=f)zSerialize an arbitrary value to a JSON string. Args: value (Any): The value to encode. Returns: str: JSON string. Raises: ValueError: If the value cannot be encoded to JSON. zFailed to serialize value: z: )r5r,dumps Exception ValueErrortype)rrserialized_values rrJsonSerializer.serializebsW U#33E: ::./ / U:4;-r%ST T Us &)&AcR[U[5(aURS5(a8URS5(a"[US5nUR US5$URS5(a8URS5(a"[US5nUR US5$UR 5VVs0sHup4X0RU5_M snn$[U[5(a!UVs/sHoPRU5PM sn$U$s snnfs snf)zHelper to deserialize a single dict or other json value from its discriminator fields back into a python class. Args: data (Any): a dict, list, string, number, or boolean Returns: Any: The deserialized value. r.r+rr*) r1r3getr model_validate from_dictr4deserialize_valuer6)rdata module_classr8r9r:s rrG JsonSerializer.deserialize_valuets dD ! !xx((TXX6F-G-G@FVAWX #224=AA*++9I0J0J@FVAWX #--d7m<<=AZZ\J\TQA--a00\J J d # #=ABTT**40TB B KBs D?D$cP[R"U5nURU5$)zDeserialize a JSON string into Python objects. Args: value (str): JSON string. Returns: Any: The reconstructed value. )r,loadsrG)rrrHs rrJsonSerializer.deserializes#zz% %%d++rrN)rrrrr)rHrrrr) rr r!r"r#r5rrGrr$rrrr&r&$s4!FU$* ,rr&c@^\rSrSrSrSU4SjjrSU4SjjrSrU=r$)PickleSerializera Hybrid serializer: JSON when possible, Pickle as a safe fallback. This serializer attempts JSON first for readability and portability, and transparently falls back to Pickle for objects that cannot be represented in JSON. Deserialization prioritizes Pickle and falls back to JSON. Warning: Pickle can execute arbitrary code during deserialization. Only deserialize trusted payloads. Note: Used to be called `JsonPickleSerializer` but it was renamed to `PickleSerializer`. Examples: ```python s = PickleSerializer() class Foo: def __init__(self, x): self.x = x payload = s.serialize(Foo(1)) # will likely use Pickle obj = s.deserialize(payload) assert isinstance(obj, Foo) ``` c>[TU]U5$![a< [R"[ R "U55RS5s$f=f)zSerialize with JSON preference and Pickle fallback. Args: value (Any): The value to encode. Returns: str: Encoded string (JSON or base64-encoded Pickle bytes). zutf-8)superrr>base64 b64encodepickler=decoderr __class__s rrPickleSerializer.serializesO I7$U+ + I##FLL$78??H H IsAAAc>[R"[R"U55$![a [ TU]U5s$f=f)zDeserialize with Pickle preference and JSON fallback. Args: value (str): Encoded string. Returns: Any: The reconstructed value. Notes: Use only with trusted payloads due to Pickle security implications. )rUrLrS b64decoder>rRrrWs rrPickleSerializer.deserializesA .<< 0 0 78 8 .7&u- - .s)-A A rrr) rr r!r"r#rrr$ __classcell__)rXs@rrOrOs2 I..rrO) __future__rrSr,rUabcrrtypingrpydanticrutilsr r r r&rOJsonPickleSerializerrrrrdsO# #H2S2&o,^o,d7.~7.t(r