c i68dZddlmZddlmZmZddlmZddlm Z m Z m Z m Z e dZ e dZ ddlmZdd lmZn#e$rd Zd ZYnwxYw dd lmZdd lmZn!#e$rd ZGd de e ZYnwxYwgdZd%dZd dd&dZd d d dd'd$Zd S)(zKey/value cache for use inside LangGraph deployments. Thin wrapper around ``langgraph_api.cache``. Values must be JSON-serializable (dicts, lists, strings, numbers, booleans, ``None``). ) annotations) AwaitableCallable) timedelta)AnyGenericLiteralTypeVarT)missfreshstaleexpired) cache_get) cache_setN) SWRResult)swrc2eZdZUdZded<ded<d d dZd S) rz'Result wrapper returned by :func:`swr`.r value CacheStatusstatus.returnc KdS)z&Update or revalidate the cached value.N)selfrs C:\Users\Dell Inspiron 16\Desktop\tws\AgrotaPowerBi\back-agrota-powerbi\mcp-client-agrota\venv\Lib\site-packages\langgraph_sdk/cache.pymutatezSWRResult.mutate+s CN).)rr rr )__name__ __module__ __qualname____doc____annotations__rrrrrr%sJ55       rr)rrrrkeystrr Any | Nonec\Kttdt|d{VS)zGet a value from the cache. Returns the deserialized value, or ``None`` if the key is missing or expired. Requires Agent Server runtime version 0.7.29 or later. NyCache is only available server-side within the LangGraph Agent Server (https://docs.langchain.com/langsmith/deployments).) _cache_get RuntimeError)r$s rrr8sF B   C  r)ttlrrr+timedelta | NoneNonecdKttdt|||d{VdS)a%Set a value in the cache. Args: key: The cache key. value: The value to cache (must be JSON-serializable). ttl: Optional time-to-live. Capped at 1 day; ``None`` or zero defaults to 1 day. Requires Agent Server runtime version 0.7.29 or later. Nr() _cache_setr*)r$rr+s rrrGsR B    S% % %%%%%%%%%%r fresh_formax_agemodelloaderCallable[[], Awaitable[T]]r1r2r3type[T] | None SWRResult[T]cKttd|td}|td}t|||||d{VS)aLoad a cached value using stale-while-revalidate semantics. This helper is server-side only and is intended for caching internal async dependencies such as auth or metadata lookups. Args: key: Cache key. loader: Async callable that fetches the value on miss/revalidation. fresh_for: How long a cached value is considered fresh (no revalidation). Defaults to ``timedelta(0)`` so every access triggers a background revalidate while still returning the cached value instantly. Values above :data:`MAX_CACHE_TTL` are clamped to the backend maximum. max_age: Total lifetime of a cached entry. After this, the next access blocks on the loader. Defaults to :data:`MAX_CACHE_TTL` (24 h by default). Values above :data:`MAX_CACHE_TTL` are clamped to the backend maximum. model: Optional Pydantic model class. When provided, values are serialized via ``model_dump(mode="json")`` before storage and deserialized via ``model.model_validate()`` on read. Returns: An :class:`SWRResult` with ``.value``, ``.status``, and an async ``.mutate()`` method. Semantics: - cache miss: await ``loader()``, store the value, return it - fresh hit (age < fresh_for): return the cached value - stale hit (fresh_for <= age < max_age): return the cached value immediately and trigger a best-effort background refresh - expired (age >= max_age): await ``loader()``, store the value, return it Nr(r)daysr0)_api_swrr*r)r$r4r1r2r3s rrrZsN B   aLL ### Vy'      r)r$r%rr&)r$r%rrr+r,rr-) r$r%r4r5r1r,r2r,r3r6rr7)r" __future__rcollections.abcrrdatetimertypingrrr r r rlanggraph_api.cacherr)rr/ ImportErrorrrr;__all__rrrrCs#"""""////////111111111111 GCLL9:  JJJJ ------3333333   HGAJ     ! ! ! !FJ&&&&&&.#' $ 22222222s# A AA A!!A?>A?