tj?ddlmZddlmZddlmZmZddlmZddl m Z m Z ddl m Z mZmZmZddlmZddlmZmZmZdd lmZdd lmZmZmZmZmZmZm Z e!ed d Z"e!ed dZ#dBdZ$dCdZ%dDdZ&dEdZ'dFd"Z(dGd$Z)dHd&Z*d'd'd'd'd'd(dId1Z+ dJdKd5Z, dJdLd7Z-dMd9Z.dHd:Z/d;Z0dNd=Z1dOd>Z2e3d?Z4dPdAZ5d'S)Q) annotations)ChainMap)MappingSequence)getenv)Anycast)AsyncCallbackManagerBaseCallbackManagerCallbackManager Callbacks)RunnableConfig) CONFIG_KEYS COPIABLE_KEYSvar_child_runnable_config)CheckpointMetadata)_CHECKPOINT_COORDINATE_KEYSCONFCONFIG_KEY_CHECKPOINT_IDCONFIG_KEY_CHECKPOINT_MAPCONFIG_KEY_CHECKPOINT_NSNS_ENDNS_SEP!LANGGRAPH_DEFAULT_RECURSION_LIMIT10007-LANGGRAPH_DELTA_MAX_SUPERSTEPS_SINCE_SNAPSHOT5000nsstrreturncntjd|tDS)zRemove task IDs from checkpoint namespace. Args: ns: The checkpoint namespace with task IDs. Returns: str: The checkpoint namespace without task IDs. c3~K|]8}||tdV9dS)rN)isdigitsplitr).0parts Y/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/langgraph/_internal/_config.py z'recast_checkpoint_ns../sT"&$,,.. 61)rjoinr$)rs r'recast_checkpoint_nsr+&s@ ;*,((6*:*:  r)configRunnableConfig | Nonepatchdict[str, Any]rc|| t|iSt|vr i|t|iSi|ti|t|iSN)r)r,r.s r'patch_configurabler24sW~e} V  &&&$&&&:&:$ 96$< 95 9:::r)metadataCheckpointMetadata | Nonec||S|r|dndx}r@|t}t|ti||t|t iiS|S)Nparents)getrr2rrr)r,r3r6confs r'patch_checkpoint_mapr9?s~ 08BX\\),,,d C d|! ),,12D9Q4R,,     r)valuercNt|trt|n|Sr1) isinstancerdictr:s r'_copy_mapping_valuer?Ss!$UG44 ?4;;;%?r)baseMapping[str, Any] | Nonenewcd|piD}|piD]\}}|dkrrt||trJt|tr5it tt t f|||||<}t|||<|S)uMerge metadata without mutating inputs. Top-level keys merge with newer values winning. `lc_versions` is the only mapping-valued key that merges one level deeper, so independent LangChain packages can contribute package versions without changing generic metadata semantics. Mapping values are copied one level, so deeper nested objects remain shared. `None` inputs are treated as empty metadata. Mirrors `langchain_core.runnables.config._merge_metadata_dicts` so configs that pass through LangGraph's merge keep the same `lc_versions` semantics; keep the two in sync. Unlike lc-core, this copies mapping values one level (intentionally more defensive — do not "simplify" back to a shared ref). c4i|]\}}|t|S)r?)r%keyr:s r' z#_merge_metadata..gs' U U U*#uc&u-- U U Ur) lc_versions)itemsr<r7rr rrr?)r@rBmergedrFr:s r'_merge_metadatarKWs V U@R@R@T@T U U UFyb'')) 5 5 U = 6::c??G44 !5'** !wsCx(&+66F3KK .e44F3KK Mr)r c||S|2t|ttfr|n|St|trbt|tr||zSt|tr2|}|D]}||d|Snt|trqt|tr2|}|D]}||d|St|tr||St dt|dt|)zMerge two callbacks values (None / list / BaseCallbackManager). Six cases total (3 base types x 2 non-None new types). NT)inheritzUnsupported callback types: z, )r<listr copy add_handlermergeNotImplementedErrortype)r@rBmngrcbs r'_merge_callbacksrVwsp  {  |'d4G-HIIRsxxzzzsR#t# dD ! ! #:  d/ 0 0 99;;D 3 3  T 2222K   C, - -# dD ! ! 88::D 3 3  T 2222K d/ 0 0 #::c?? " VT$ZZVV4PS99VV W WWr)configsc i}|D]n}||D]R\}}|s |dkrtttttt fdz||tttt f|||<|dkr'||x}r g||||<|||<|tkr'||x}r i||||<|||<|dkr;t|dtt||d<#|dkr|dtkr |d|d<G||||<Tpt|vr i|t<|S)zMerge multiple configs into one. Args: *configs: The configs to merge. Returns: RunnableConfig: The merged config. Nr3tags callbacksrecursion_limit) rIrKr rrrr7rrVr DEFAULT_RECURSION_LIMIT)rWr@r,rFr: base_values r' merge_configsr^sD(( >  ,,.. ( (JC j  +c*T1488C==AAc*E22S !%#.:& 5* 5u 5DII %DII!%#.:& 7: 7 7DII %DII ##$4HH[))4 5+A+A%%[!!)))+,0GGG.45F.GD*+"3KS 5 (6 4T Kr)N)rZr[max_concurrencyrun_name configurablerZr[ int | Noner_r` str | Noneradict[str, Any] | Nonec||ni}|||d<d|vr|d=d|vr|d=|||d<|||d<|||d<|'i|ti||t<|S)aPatch a config with new values. Args: config: The config to patch. callbacks: The callbacks to set. recursion_limit: The recursion limit to set. max_concurrency: The max number of concurrent steps to run, which also applies to parallelized steps. run_name: The run name to set. configurable: The configurable to set. Returns: RunnableConfig: The patched config. NrZr`run_idr[r_)rOr7r)r,rZr[r_r`ras r' patch_configrgs,%0V[[]]]bF({   z" v  x "$3 !"$3 !%z?&**T2..?,?t Mr)rYSequence[str] | Noner cddlm}|d}| |g||}n|t|}|dx}rVt ||rF|r|||dx}r|||}nG|j|d||dt|}|S)zGet a callback manager for a config. Args: config: The config. Returns: CallbackManager: The callback manager. r)r rYNrZr3inheritable_callbacksinheritable_tagsinheritable_metadatalangsmith_inheritable_metadata) langchain_core.callbacks.managerr r7rNr<add_tags add_metadata configure_get_tracing_metadata_defaults)r,rYr all_tagsrZr3managers r'get_callback_manager_for_configrvs&A@@@@@zz&!!H 0%X%% ::ZZ ,,,  *?33   )   x ( ( (zz*-- -8 -  " "8 , , ,,/+"(**["9"9%!'J!7!7+I&+Q+Q     Nr)r cddlm}|d}| |g||}n|t|}|dx}rVt ||rF|r|||dx}r|||}nG|j|d||dt|}|S)zGet an async callback manager for a config. Args: config: The config. Returns: AsyncCallbackManager: The async callback manager. r)r rYNrZr3rj) ror r7rNr<rprqrrrs)r,rYr rtrZr3rus r'%get_async_callback_manager_for_configrxs(FEEEEEzz&!!H 0%X%% ::ZZ ,,,  *'33   )   x ( ( (zz*-- -8 -  " "8 , , ,1&0"(**["9"9%!'J!7!7+I&+Q+Q     Nr)boolctt|tttfrt |dkS|duS)Nr)r<rNtupler=lenr>s r' _is_not_emptyr};s6%$t,--!5zzA~D  r)c  tgtdti}tjx}r1|d|D|trQ|D]N}||t s"t fdtDr i|t<nO|D]}||D]\}}t|r|tvr|tkrn||}|r,itt|tt|n&tt|||<|dkr:t|dtt ||d<|dkrut#tt$t&t(fdz|dtt$t&t(f||d<T|dkrW|d}|rg|tt*|n!t+tt*||d<|||<|D]-\}}t|r|tvr||t|<.|d}|d} |r-| +t,D]#} | | vr|| } | r| | | <$|S) zReturn a config with all keys, merging any provided configs. Args: *configs: Configs to merge before ensuring defaults. Returns: RunnableConfig: The merged and ensured config. N)rYr3rZr[racri|]4\}}t|||tvr|n|5SrE)r}rrO)r%kvs r'rGz!ensure_config..TsR   Aq ## qM11166888q   r)c3\K|]&}t|V'dSr1)r}r7)r%rexplicit_configurables r'r(z ensure_config..jsN377::;;r)rZr3rYra)rrr\rr7updaterIranyrr}rr r=rOrVr rKrrrrN_PROPAGATE_TO_METADATA) rWempty var_configr,rrexisting existing_tagsrar3rFr:rs @r' ensure_configrBs  /    E/2444z    &,,..       yy   F~$*JJt$4$4 !( 4 !d    )#)# > LLNN# !# !DAqQ" !A$4$499 %yy||H$2A4h//A4a==AA!$]]//11!HH +%%)9 +..Y0B0B**E+&&*__)8WS#X.5uyy7L7LMMWS#X.22))E*%%&[[7.s(77vv"777777r)) casefold startswithr<rintfloatryr_OMIT)rFr:rs @r'_exclude_as_metadatarsg I t 8%#sE4!899 9 8 7777777 7 7r)c|d}|sdSi}|D]\}}t||r|||<|pdS)z;Get tracer-only metadata defaults from configurable values.raN)r7rIr)r,rar3rFr:s r'rsrssq::n--L t!H"((** U U + +    tr)) thread_id checkpoint_id checkpoint_nstask_idrf assistant_idgraph_idlist[str] | Nonec*|sdSd|D}|pdS)awDrop langgraph's internal `seq:step:*` bookkeeping tags. `seq:step:N` tags are added internally to mark sequence steps; everything else (user-supplied tags and any other framework tags) is kept. Returns the surviving tags, or `None` if none remain. Shared by the `messages` and `tasks` stream handlers so both surface the same tag set on their metadata. Nc<g|]}|d|S)zseq:step)r)r%ts r' z'filter_to_user_tags..s)@@@aq||J'?'?@@@@r)rE)rYfiltereds r'filter_to_user_tagsrs/ t@@4@@@H  tr))rrr r)r,r-r.r/r r)r,r-r3r4r r)r:rr r)r@rArBrAr r/)r@r rBr r r )rWr-r r)r,r-rZr r[rbr_rbr`rcrardr rr1)r,rrYrhr r )r,rrYrhr r )r:rr ry)rFrr:rr ry)r,rr rd)rYrhr r)6 __future__r collectionsrcollections.abcrrosrtypingrr langchain_core.callbacksr r r r langchain_core.runnablesrlangchain_core.runnables.configrrrlanggraph.checkpoint.baserlanggraph._internal._constantsrrrrrrrrr\#DELTA_MAX_SUPERSTEPS_SINCE_SNAPSHOTr+r2r9r?rKrVr^rgrvrxr}rrrrs frozensetrrrEr)r'rs3"""""" -------- 433333 988888#ff%H'RRSS&)c F :FCC''#    ;;;;(@@@@@XXXX8,,,,d "&"&*.''''''V:>$$$$$R"&%%%%%P!!!!bbbbJ 7    #        r)