<i*SSKJr SSKJrJr SSKJrJrJrJ r SSK J r J r SSK JrJrJr SSKJr SSKJr SSKJr SS KJr \\\\\4/S 4r\"S \ S 9r\"5r\"5r"S S\5r "SS\5r!"SS\5r"SSjr#g )) annotations)CallableSequence)Any NamedTupleTypeVarcast)RunnableRunnableConfig)CONFCONFIG_KEY_SENDTASKS)RunnableCallable)MISSING)InvalidUpdateError)SendNR)boundcP\rSrSr%S\S'\rS\S'SrS\S'S rS \S 'S r g ) ChannelWriteEntrystrchannelrvalueFbool skip_noneNzCallable | Nonemapper) __name__ __module__ __qualname____firstlineno____annotations__ PASSTHROUGHrrr__static_attributes__rg/home/dmtnaga/Documents/work/airagagent/rag_env/lib/python3.13/site-packages/langgraph/pregel/_write.pyrrs1 L#E3:It7"FO"9r&rc@\rSrSr%S\S'\rS\S'SrS\S'S rg) ChannelWriteTupleEntry%z1Callable[[Any], Sequence[tuple[str, Any]] | None]rrrN,Sequence[tuple[str, Any, str | None]] | Nonestaticr) rr r!r"r#r$rr,r%rr&r'r)r)%s& ==0E3:;?F 8?8r&r)c^\rSrSr%SrS\S'SS.SU4SjjjrSSS.SU4S jjjjrSS jrSS jr \ SSS jj5r \ SS j5r \ SSj5r \ SSSjj5rSrU=r$) ChannelWrite.zImplements the logic for sending writes to CONFIG_KEY_SEND. Can be used as a runnable or as a static method to call imperatively.z7list[ChannelWriteEntry | ChannelWriteTupleEntry | Send]writesN)tagsc>[TU]URURSUSS9 [ [ [ [-[-U5Ul g)NF)funcafuncnamer1trace) super__init___write_awriter listrr)rr0)selfr0r1 __class__s r'r8ChannelWrite.__init__5sR ,,   "%;;dB CV  r&r5cx>U(d&SSRSUR55S3n[TU] XS9$)Nz ChannelWrite<,c3# UHIn[U[5(a URO"[U[5(aSO URv MK g7f)z...N) isinstancerrr)node).0ws r' (ChannelWrite.get_name..Hsl,pdo_`AGX9Y9YAIIhrstwMiNiN_dTUTZTZ-ZdosAA>r?)joinr0r7get_name)r<suffixr5r=s r'rKChannelWrite.get_nameFs^"388,pdhdodo,p$p#qqrsDw22r&c URVs/sHn[U[5(a>UR[La+[UR XR UR5O?[U[5(a)UR[La[URU5OUPM nnURUU5 U$s snfN r0rCrrr$rrrr)do_writer<inputconfigwriter0s r'r9ChannelWrite._writeKs  % %!233 {8R emmUOOU\\ R%!788U[[K=W( e<   %       sBCc # URVs/sHn[U[5(a>UR[La+[UR XR UR5O?[U[5(a)UR[La[URU5OUPM nnURUU5 U$s snf7frOrPrRs r'r:ChannelWrite._awriteZs  % %!233 {8R emmUOOU\\ R%!788U[[K=W( e<   %       sC BC.C cUHn[U[5(aDUR[:Xa [ S5eUR [ LaU(d [ S5e[U[5(dMsUR [ LdMU(aM[ S5e U[[nU"[U55 g)Nz*Cannot write to the reserved channel TASKSz"PASSTHROUGH value must be replaced) rCrrrrrr$r)r r _assemble_writes)rTr0allow_passthroughrFrUs r'rQChannelWrite.do_writeisA!.//99%,D77k)2C,-QRR!34477k)2C2C,-QRR"$<8 v&'r&c^[U[5=(d [US[5[L$)zFUsed by PregelNode to distinguish between writers and other runnables._is_channel_writer)rCr.getattrr)runnables r' is_writerChannelWrite.is_writers+ x . Ox!5w?wN r&c[U[5(afURVVs/sHCn[U[5(dMUR(dM-URHnUPM ME snn=(d S$[ US[ 5=n(aU[ La[[[[[-[S-4U5nUVVs/sHupEUPM nnnUVVs/sHupWUPM nnn[[U5U5V Vs/sH up/U QUP7PM snn $ggs snnfs snnfs snnfs snn f)zEUsed to get conditional writes a writer declares for static analysis.Nr^)rCr.r0r)r,r_rr rtuplerrrziprZ) r`entryrFr0e_entrieslalabelsts r'get_static_writesChannelWrite.get_static_writess1 h - -&__,Ee%;<AFA&,    x)=wG GV GW$U#4t#;S4Z#GHI*0010*01&"&1.12B72KV.TU.TUQ!R.TUU%H 11Us#D(D(D(D.&D4D:c4[RUSU5 U$)zUsed to mark a runnable as a writer, so that it can be detected by is_writer. Instances of ChannelWrite are automatically marked as writers. Optionally, a list of declared writes can be passed for static analysis.r^)object __setattr__)r`r,s r'register_writerChannelWrite.register_writers 8%96Br&)r0)r0;Sequence[ChannelWriteEntry | ChannelWriteTupleEntry | Send]r1zSequence[str] | NonerO)rL str | Noner5rureturnr)rSrrTr rvNone)T)rTr r0rtr[rrvrw)r`r rvr)r`r rvr+)r`rr,z/nUGHn[U[5(aUR[U45 M2[U[5(a7UR UR 5=n(aURU5 M|M~[U[5(auUR bUR UR 5O UR nU[LaMUR(aUcMURURU45 GM[SU35e U$)z+Assembles the writes into a list of tuples.zInvalid write entry: ) rCrappendrr)rrextendr SKIP_WRITErr ValueError)r0tuplesrFwwrs r'rZrZs%'F  a   MM5!* % 1 2 2XXagg&&r& b!' , - -)*)=AHHQWW%177E "{{u} MM199e, -4QC89 9 Mr&)r0rtrvzlist[tuple[str, Any]])$ __future__rcollections.abcrrtypingrrrr langchain_core.runnablesr r langgraph._internal._constantsr r rlanggraph._internal._runnablerlanggraph._internal._typingrlanggraph.errorsrlanggraph.typesrrdr TYPE_SENDrrpr~r$rr)r.rZrr&r'rs".>GG:// huS#X/0$6 7  Cx  X h : :9Z9{#{| Gr&