"j SrSSKJr SSKJr SSKJr SSKJr SSK J r J r J r \"SSS 9r \"S SS 9r\"S SS 9r"S S \\5r"SS\\5r\"SS\\\455rg)zCore node types for graph construction and execution. This module defines the fundamental node types used to build execution graphs, including start/end nodes and fork nodes for parallel execution. ) annotations) dataclass)Generic)TypeVar)ForkIDJoinIDNodeIDStateTT)infer_varianceOutputTInputTc(\rSrSrSr\"S5rSrg) StartNodeziEntry point node for graph execution. The StartNode represents the beginning of a graph execution flow. __start__N)__name__ __module__ __qualname____firstlineno____doc__r id__static_attributes__rP/home/mande/repo/quber/.venv/lib/python3.13/site-packages/pydantic_graph/node.pyrrs  B.rrc4\rSrSrSr\"S5rSSjrSrg)EndNode$zTerminal node representing the completion of graph execution. The EndNode marks the successful completion of a graph execution flow and can collect the final output data. __end__c[S5e)zForce type variance for proper generic typing. This method exists solely for type checking purposes and should never be called. Args: inputs: Input data of type InputT. Raises: RuntimeError: Always, as this method should never be executed. KThis method should never be called, it is just defined for typing purposes. RuntimeErrorselfinputss r_force_varianceEndNode._force_variance.shiirrN)r&r returnNone) rrrrrr rr'rrrrrr$s  B, jrrcH\rSrSr%SrS\S'S\S'S\S'S S jrS rg ) Fork<aFork node that creates parallel execution branches. A Fork node splits the execution flow into multiple parallel branches, enabling concurrent execution of downstream nodes. It can either map a sequence across multiple branches or duplicate data to each branch. rrboolis_mapz JoinID | Nonedownstream_join_idc[S5e)a3Force type variance for proper generic typing. This method exists solely for type checking purposes and should never be called. Args: inputs: Input data to be forked. Returns: Output data type (never actually returned). Raises: RuntimeError: Always, as this method should never be executed. r!r"r$s rr'Fork._force_varianceQshiirrN)r&r r)r )rrrrr__annotations__r'rrrrr,r,<s, J/ L &%njrr,N)r __future__r dataclassesrtypingrtyping_extensionsrpydantic_graph.id_typesrrr r r r rrr,rrrr9s #!%:: $ /$ )D 1) $ /(/ /jgfoj0 "j767? #"j "jr