@@ -156,21 +156,6 @@ def is_error_source(cls, x: Any) -> TypeGuard[ErrorSource[T, S]]:
156156 cls .is_single_error_source_list (x )
157157 )
158158
159- # @classmethod
160- # def is_single_branch_source(cls, x: Any) -> TypeGuard[SingleBranchSource[T, S]]:
161- # return x is START or cls.is_single_source(x)
162-
163- # @classmethod
164- # def is_single_branch_source_list(cls, x: Any) -> TypeGuard[list[SingleBranchSource[T, S]]]:
165- # return isinstance(x, list) and all(cls.is_single_branch_source(n) for n in cast(list[Any], x))
166-
167- # @classmethod
168- # def is_branch_source(cls, x: Any) -> TypeGuard[BranchSource[T, S]]:
169- # return (
170- # cls.is_single_branch_source(x) or
171- # cls.is_single_branch_source_list(x)
172- # )
173-
174159 @classmethod
175160 def is_any_single_source (cls , x : Any ) -> TypeGuard [SingleSourceWithConfig [T , S ] | SingleErrorSource [T , S ]]:
176161 return cls .is_single_source_with_config (x ) or cls .is_single_error_source (x )
@@ -188,16 +173,6 @@ def is_branch_join(cls, x: Any) -> TypeGuard[BranchJoin[T, S]]:
188173 return x is END or cls .is_next (x )
189174
190175
191- # class Config(BaseModel):
192- # """
193- # Configuration for the edge.
194-
195- # Attributes:
196- # instant: If the edge should be executed parallel to the source node. Instant edges are traversed recursively. Make sure to avoid infinite loops.
197- # """
198-
199- # instant: bool = False
200-
201176class ErrorConfig (BaseModel ):
202177 """
203178 Configuration for the error edge.
0 commit comments