ޠj"%SrSSKJr SSKrSSKrSSKrSSKJr SSKJ r SSK J r J r J r SSKJrJr SSKrSSKrSSKJr \ (aSS KJr S r\ "S\"55r\4SS jjrSS jrSS jr\R:"S5rSSjrS Sjr S!Sjr!S"Sjr"S#Sjr#S$Sjr$S%Sjr%/r&S\'S'S&Sjr(\RR"SS9S'Sj5r*g)(z4Shared utility functions for async and sync clients.) annotationsN)Mapping)tzinfo) TYPE_CHECKINGAnycast)quoteurlparse)RunCreateMetadata)ZoneInfo) x-api-keyc[U[5(aU$U[LaYSHSn[R"US35=n(dM%UR 5R S5R S5s $ g)aGet the API key from the environment. Precedence: 1. explicit string argument 2. LANGGRAPH_API_KEY (if api_key not provided) 3. LANGSMITH_API_KEY (if api_key not provided) 4. LANGCHAIN_API_KEY (if api_key not provided) Args: api_key: The API key to use. Can be: - A string: use this exact API key - None: explicitly skip loading from environment - NOT_PROVIDED (default): auto-load from environment variables ) LANGGRAPH LANGSMITH LANGCHAIN_API_KEY"'N) isinstancestr NOT_PROVIDEDosgetenvstrip)api_keyprefixenvs Y/var/www/html/gaurav/venv/lib/python3.13/site-packages/langgraph_sdk/_shared/utilities.py _get_api_keyrsj'3,=Fii6(( 344s4yy{((-33C88> cU=(d 0n[HnX!;dM [SUS35e SS[R30UEn[ U5nU(aXCS'U$)z1Combine api_key and custom user-provided headers.zCannot set reserved header 'rz User-Agentzlanggraph-sdk-py/r )RESERVED_HEADERS ValueError langgraph_sdk __version__r)rcustom_headersheaderheadersresolved_api_keys r _get_headersr*3su $)rN"  #;F81EF F# )-*C*C)DE G$G,/  Nr c[U[5n[US5(aD[UR5(a*U(a[ SU<SU<35eUR 5$[US5(aD[UR 5(a*U(a[ SU<SU<35eUR 5$[U[[45(a [U5$[ S[U5S35e)N model_dumpz#Cannot JSON-serialize type object: zI. Did you mean to pass an instance of the object instead? Received type: dictzObject of type z is not JSON serializable) rtypehasattrcallabler, TypeErrorr-set frozensetlist)objis_classs r_orjson_defaultr7Hs#t$HsL!!hs~~&>&> 5cW=$$'7, ~~ f  (388"4"4 5cW=$$'7, xxz C#y) * *Cy/$s)4MNOOr z5(\/threads\/(?P.+))?\/runs\/(?P.+)cURRS5=n(aM[RU5=n(a1[ UR S5UR S5=(d SS9$g)z/Extract run metadata from the response headers.zContent-Locationrun_id thread_idN)r9r:)r(get_RUN_METADATA_PATTERNsearchr group)responsecontent_locationmatchs r_get_run_metadata_from_responserBdsh%,,001CDDD&--.>??? ;;x(kk+.6$  r cUS:XagURS5nUSn[U5S:aUSSO/nX4US.nUS:Xa,[U[5(aUR S/5US 'U$/US 'U$) zuConvert an SSE event+data pair into a v2 stream part dict. Returns None for ``end`` events (signals end of stream). endN|r)r.nsdatavalues __interrupt__ interrupts)splitlenrr-pop)eventrHparts event_typerGresults r_sse_to_v2_dictrSss  ~ KK EqJ%j1nqr"B&0DIFX*T4"8"8#xx<| M "| Mr c6Ub[U[5(aU$[U[5(aJ[USS5n[U[5(aU$UR S5nUbU$[ SU<S35e[ S[U5R35e)a{Convert a timezone argument to an IANA timezone string. Accepts: - A string (returned as-is, assumed to be an IANA timezone name) - A ``datetime.tzinfo`` instance (e.g. ``zoneinfo.ZoneInfo("America/New_York")``, ``datetime.timezone.utc``). The ``key`` attribute is used if available, otherwise ``tzname(None)`` is used. - ``None`` (returned as ``None``) Nkeyz$Cannot determine timezone name from zL. Use a zoneinfo.ZoneInfo instance or pass a string like 'America/New_York'.z9Expected str, datetime.tzinfo, or None for timezone, got ) rrrgetattrtznamer#r1r.__name__)tzrUnames r_resolve_timezoner[s zZC(( "fb%& c3  Jyy  K22&9Y Y    CDHDUDUCVW r cUS:XaS$S$)NhttpsiP)schemes r _default_portrasG#3++r c[U5nUR(dUR(dU$[UR5nU[UR5UR =(d [ U54nURUR=(d SUR =(d [ UR54nXE:wa[SU<SUSU35eU$)zValidate that a reconnect Location URL is same-origin as the base URL. Raises ValueError if the Location header points to a different origin (scheme + host + port), which would leak credentials to an external server. z4Refusing to follow cross-origin reconnect Location: z (origin z!) does not match base URL origin ) r r`netlocrhostportrahostnamer#)base_urllocationparsed base_scheme base_origin loc_origins r_validate_reconnect_locationrns h F ==hoo&K HMM 3{3K  2 3}V]]3J  B8,O!l"CK= R   Or c`UR5VVs0sH upUcM X_M snn$s snnfN)items)dkvs r_provided_valsrus(WWY 8YTQ!DADY 88 8s**cUc [S5e[U[[45(a [S5e[ [ U5SS9nU(a%[ SU55(aS[U5-nU$)aAEncode a value for safe interpolation into a request path segment. Path segments are encoded with ``safe=""`` so that ``/`` and other reserved characters are escaped. Standalone dot-segments (``.`` and ``..``) are also encoded because some URL-handling stacks (including ``httpx``) collapse them client-side as relative-path traversal before transmission. The value is coerced to ``str`` so callers can pass ``uuid.UUID`` and similar types directly without changing call sites. A properly formed identifier (for example, a standard UUID, which contains no dots or reserved characters) round-trips through this function unchanged. Raises: TypeError: If `value` is `None` or a `bytes`/`bytearray` instance. Coercing those would produce misleading paths (e.g. `/threads/None`), so surface the caller bug instead. zpath parameter must not be Nonez9path parameter must not be bytes; pass a str or uuid.UUIDrc)safec3(# UH oS:Hv M g7f).Nr_).0cs r $_quote_path_param..s/13hsz%2E)r1rbytes bytearrayr rallrM)valuequoteds r_quote_path_paramrsk& }9::%%+,,STT 3u:B 'F #////V$ Mr zlist[httpx.ASGITransport]_registered_transportsc*[H nXlM grp)rapp)r transports rconfigure_loopback_transportsrs+  ,r rF)maxsizechSSKJn UR$![a [Rs$f=f)Nrasgi_transport) langgraph_apir ASGITransport ImportErrorhttpxrs rget_asgi_transportrs1#0+++ #"""#s 11)r str | Nonereturnr)rrr&zMapping[str, str] | Nonerzdict[str, str])r5rrr)r?zhttpx.ResponserzRunCreateMetadata | None)rOrrHrrzdict[str, Any] | None)rYzstr | tzinfo | ZoneInfo | Nonerr)r`rrint)rhz httpx.URLrirrr)rrzMapping[str, Any]rzdict[str, Any])rrrr)rrrNone)rztype[httpx.ASGITransport])+__doc__ __future__r functoolsrrecollections.abcrdatetimertypingrrr urllib.parser r rr$langgraph_sdk.schemar zoneinfor r"objectrrr*r7compiler<rBrSr[rarnrurr__annotations__r lru_cacherr_r rrs:" #++( 2!!D&(# (42 ,*P. <   $<,<9B5716  Q# #r