D_i=SrSSKJrJrJrJrJrJr SSKJ r J r SSK J r J r SSKJr SSKJrJrJrJr SSKJrJrJrJrJr SSKJrJrJrJr S r "S S \\\45r!g ) z?Runnable that selects which branch to run based on a condition.) AsyncIterator AwaitableCallableIteratorMappingSequence)Anycast) BaseModel ConfigDict)override)Runnable RunnableLikeRunnableSerializablecoerce_to_runnable)RunnableConfig ensure_config%get_async_callback_manager_for_configget_callback_manager_for_config patch_config)ConfigurableFieldSpecInputOutputget_unique_config_specsc B^\rSrSr%Sr\\\\\ 4\\\ 44\ S'\\\ 4\ S'S\\\\ 4\ \/\ 4-\ \/\ \ 4-\4\-SS4U4Sjjr\"SS 9r\S\ 4S j5r\\S\\4S j55r\SS \S-S\\4U4S jjj5r\\S\\4Sj55r\SS\S \S-S\S\ 4Sjj5r \SS\S \S-S\S\ 4Sjj5r!\SS\S \S-S\S-S\"\ 4Sjj5r#\SS\S \S-S\S-S\$\ 4Sjj5r%Sr&U=r'$)RunnableBranch*a`Runnable` that selects which branch to run based on a condition. The `Runnable` is initialized with a list of `(condition, Runnable)` pairs and a default branch. When operating on an input, the first condition that evaluates to True is selected, and the corresponding `Runnable` is run on the input. If no condition evaluates to `True`, the default branch is run on the input. Examples: ```python from langchain_core.runnables import RunnableBranch branch = RunnableBranch( (lambda x: isinstance(x, str), lambda x: x.upper()), (lambda x: isinstance(x, int), lambda x: x + 1), (lambda x: isinstance(x, float), lambda x: x * 2), lambda x: "goodbye", ) branch.invoke("hello") # "HELLO" branch.invoke(None) # "goodbye" ``` branchesdefaultreturnNc L>[U5[:a Sn[U5eUSn[U[[ [ 45(d Sn[U5e[S[[SU555n/nUSSHn[U[[45(dS[U53n[U5e[U5[:waS[U53n[U5eUupx[S [U55n[U5nURXx45 M [T U]=UUS 9 g) aA `Runnable` that runs one of two branches based on a condition. Args: *branches: A list of `(condition, Runnable)` pairs. Defaults a `Runnable` to run if no condition is met. Raises: ValueError: If the number of branches is less than `2`. TypeError: If the default branch is not `Runnable`, `Callable` or `Mapping`. TypeError: If a branch is not a `tuple` or `list`. ValueError: If a branch is not of length `2`. z-RunnableBranch requires at least two branchesz=RunnableBranch default must be Runnable, callable or mapping.zRunnable[Input, Output]rNz5RunnableBranch branches must be tuples or lists, not zARunnableBranch branches must be tuples or lists of length 2, not zRunnable[Input, bool])rr )len _MIN_BRANCHES ValueError isinstancerrr TypeErrorr rtuplelisttypeappendsuper__init__) selfrmsgr default_ branches_branch conditionrunnable __class__s Y/home/james-whalen/.local/lib/python3.13/site-packages/langchain_core/runnables/branch.pyr.RunnableBranch.__init__Js>, x== (ACS/ !2,  x )  RCC.  %'9$~w:W'X  smFfudm44,,0L>; n$6{m+88;F }F!o%"( I46H6STI)(3H   i2 3#$&   T)arbitrary_types_allowedcg)z,Return `True` as this class is serializable.Tclss r7is_lc_serializable!RunnableBranch.is_lc_serializablesr9c /SQ$)z_Get the namespace of the LangChain object. Returns: `["langchain", "schema", "runnable"]` ) langchainschemar5r<r=s r7get_lc_namespaceRunnableBranch.get_lc_namespaces 32r9configct>UR/URVVs/sHup#UPM snn-URVVs/sHup2UPM snn-nUHFnURU5R5R S5cM5URU5s $ [ TU] U5$s snnfs snnf)Nr+)r rget_input_schemamodel_json_schemagetr-)r/rF_r runnablesr5r6s r7rHRunnableBranch.get_input_schemas\\N!]]+]TQq]+ ,!]]+]TQq]+ ,  "H))&1CCEII&Q 0088 "w'//,+s B.B4c [SUR/URVVs/sHupUPM snn-URVVs/sHup!UPM snn-55$s snnfs snnf)Nc3N# UHnURHnUv M M g7fN) config_specs).0stepspecs r7 .RunnableBranch.config_specs..s5' 0 ))  * 0s#%)rr r)r/rKrLs r7rRRunnableBranch.config_specssh'' !%/1/0!%/1/0'   0/s A"A(inputkwargsc [U5n[U5nURSUURS5=(d UR 5UR SS5S9n[ UR5HmupgUupURU[UURSUS-3S9S9S 9n U (dM=U R"U4S [UURS US-3S9S90UD6n O6 URR"U4S [X%RS S9S90UD6n URU 5 U $![an URU 5 eSn A ff=f) a&First evaluates the condition, then delegate to `True` or `False` branch. Args: input: The input to the `Runnable`. config: The configuration for the `Runnable`. **kwargs: Additional keyword arguments to pass to the `Runnable`. Returns: The output of the branch that was run. Nrun_namerun_idnamer] condition:tag callbacksrFrFbranch:branch:default)rron_chain_startrJget_namepop enumeraterinvoker get_childr BaseExceptionon_chain_error on_chain_end r/rYrFrZcallback_manager run_manageridxr3r4r5expression_valueoutputes r7rmRunnableBranch.invokesv&:6B&55  J':4==?::h- 6  (7 &,# #,#3#3'"-"7"7jq URR"U4S [X%RS S9S90UD6IShvN n URU 5IShvN U $NNNcN&![a n URU 5IShvN eSn A ff=fN;7f) Nr\r]r^r`rarbrdrfrFrgrh)rrrirJrjrkrlrainvokerrnr rorprqrrs r7r{RunnableBranch.ainvokesv&@H,;;  J':4==?::h- <  (7 &,# )2):):'"-"7"7jq 8E6E7E;FF FEEE F )F=F>FF  Fc +# [U5n[U5nURSUURS5=(d UR 5UR SS5S9nSnSn[ UR5HupU upU RU[UURSUS-3S9S 9S 9n U (dM=U R"U4S [UURS US-3S9S 90UD6Hn U v U(dMUcU nMXm-nM OW URR"U4S [UURSS9S 90UD6Hn U v U(dMUcU nMXm-nM UR!U5 g![a SnS nMf=f![a SnS nMYf=f![anURU5 eSnAff=f7fa%First evaluates the condition, then delegate to `True` or `False` branch. Args: input: The input to the `Runnable`. config: The configuration for the `Runnable`. **kwargs: Additional keyword arguments to pass to the `Runnable`. Yields: The output of the branch that was run. Nr\r]r^Tr`rarbrdrfrFrgFrh)rrrirJrjrkrlrrmrrnstreamr(r rorprqr/rYrFrZrsrt final_outputfinal_output_supportedrur3r4r5rvchunkrxs r7rRunnableBranch.stream's%"v&:6B&55  J':4==?::h- 6 '+ !%5 (7 &,# #,#3#3'"-"7"7jq 6?   & &q )  sA#G&AF8'F99F>>Gc # [U5n[U5nURSUURS5=(d UR 5UR SS5S9IShvN nSnSn[ UR5HupU upU RU[UURSUS-3S9S 9S 9IShvN n U (dMEU R"U4S [UURS US-3S9S 90UD6ShvN n U 7v U(dMUcU nMXm-nM% URR"U4S [UURSS9S 90UD6ShvN n U 7v U(dMUcU nMXm-nM%GNNN![a SnS nMf=f OFN?![a SnS nMWf=f O-![a nURU5IShvN eSnAff=fUR!U5IShvN g7fr~)rrrirJrjrkrlrr{rrnastreamr(r rorprqrs r7rRunnableBranch.astream{sa"v&@H,;;  J':4==?::h- <  '+ !%5 (7 &,# )2):):'"-"7"7jq 6?$$ ,,Q/ / /  &&|444sA"G8$E8%G8.A F0:E;; F00F08F<E==F F0F0E?8F0F.FF. F0*F02F6F08G8;F0=F?F F0FF0G8F.F+'F0*F++F0/G80 G:GGGGG81G42G8r<rQ)(__name__ __module__ __qualname____firstlineno____doc__rr)rrboolr__annotations__rrrr.r model_config classmethodr?r r*strrDrr+r rHpropertyrrRr rmr{rrrr__static_attributes__ __classcell__)r6s@r7rr*st4uXeTk2HUF]4KKLMM2 eVm $$5?  UD[ !w}% &w $/0 1    ?  ? B $L4 3c330~'<0Y00    d#89    <@88$2T$98LO8 88t<@--$2T$9-LO- --^)-Q/Q/%Q/* Q/ &  Q/Q/f)-Q5Q5%Q5* Q5 v  Q5Q5r9rN)"rcollections.abcrrrrrrtypingr r pydanticr r typing_extensionsr langchain_core.runnables.baserrrrlangchain_core.runnables.configrrrrrlangchain_core.runnables.utilsrrrrr%rr<r9r7rs\E +&  c5)%-8c5r9