k i{ndZddlmZdZdZdedefdZdedefdZdedefd Zdedefd Z d edefd Z d S)a5 RediSearch versions below 2.10 don't support indexing and querying empty strings, so we use a sentinel value to represent empty strings. Because checkpoint queries are sorted by checkpoint_id, we use a UUID that is lexicographically sortable. Typically, checkpoints that need sentinel values are from the first run of the graph, so this should generally be correct. This module also includes utility functions for safely handling Redis responses, including handling bytes vs string responses depending on how the Redis client is configured with decode_responses. )Any __empty__z$00000000-0000-0000-0000-000000000000valuereturnc:|dkrtSt|S)z Prepare a value for storage in Redis as a string. Convert an empty string to a sentinel value, otherwise return the value as a string. Args: value (str): The value to convert. Returns: str: The converted value. )EMPTY_STRING_SENTINELstrrs C:\Users\Dell Inspiron 16\Desktop\tws\AgrotaPowerBi\back-agrota-powerbi\mcp-client-agrota\venv\Lib\site-packages\langgraph/checkpoint/redis/util.pyto_storage_safe_strr s {{$$5zzc |tkrdS|S)z Convert a value from a sentinel value to an empty string if present, otherwise return the value unchanged. Args: value (str): The value to convert. Returns: str: The converted value. r)r r s r from_storage_safe_strr's %%%r rc:|dkrtSt|S)a Prepare a value for storage in Redis as an ID. Convert an empty string to a sentinel value for empty ID strings, otherwise return the value as a string. Args: value (str): The value to convert. Returns: str: The converted value. r)EMPTY_ID_SENTINELr r s r to_storage_safe_idr8s {{  5zzrc |tkrdS|S)z Convert a value from a sentinel value for empty ID strings to an empty ID string if present, otherwise return the value unchanged. Args: value (str): The value to convert. Returns: str: The converted value. r)rr s r from_storage_safe_idrKs !!!r robjc|dSt|tr( |dS#t$r|cYSwxYwt|tr|St|t rd|DSt|tr d|DSt|trtd|DSt|tr d|DS|S)ax Safely decode Redis responses, handling both string and bytes types. This is especially useful when working with Redis clients configured with different decode_responses settings. It recursively processes nested data structures (dicts, lists, tuples, sets). Based on RedisVL's convert_bytes function (redisvl.redis.utils.convert_bytes) but implemented directly to avoid runtime import issues and ensure consistent behavior with sets and other data structures. See PR #34 and referenced implementation: https://github.com/redis/redis-vl-python/blob/9f22a9ad4c2166af6462b007833b456448714dd9/redisvl/redis/utils.py#L20 Args: obj: The object to decode. Can be a string, bytes, or a nested structure containing strings/bytes (dict, list, tuple, set). Returns: The decoded object with all bytes converted to strings. Nzutf-8cNi|]"\}}t|t|#S safely_decode).0kvs r z!safely_decode..{s.KKKtq! a  -"2"2KKKrc,g|]}t|Srrritems r z!safely_decode..} 444 d##444rc34K|]}t|VdS)Nrr!s r z safely_decode..s*99T]4((999999rc,h|]}t|Srrr!s r z safely_decode..r$r) isinstancebytesdecodeUnicodeDecodeErrorr dictitemslisttupleset)rs r rr\s$( {t C   ::g&& &!   JJJ  C    C   KKsyy{{KKKK C  444444 C  99S999999 C  444444 s 0 ??N) __doc__typingrr rr r rrrrrrr r4s  #:ss&"cc&"(s(s((((((r