Links the output of the source node to the input of the destination node. If the source or destination node is None, the pipeline's input or output is used.
(self, src: Union[Node, Tuple[Node, str]], dst: Union[Node, Tuple[Node, str]])
| 257 | self.nodes.append(node) |
| 258 | |
| 259 | def link(self, src: Union[Node, Tuple[Node, str]], dst: Union[Node, Tuple[Node, str]]): |
| 260 | """ |
| 261 | Links the output of the source node to the input of the destination node. |
| 262 | If the source or destination node is None, the pipeline's input or output is used. |
| 263 | """ |
| 264 | src_queue = self.input if src is None else src.output |
| 265 | dst_queue = self.output if dst is None else dst.input |
| 266 | self.links.append(Link(src_queue, dst_queue)) |
| 267 | |
| 268 | def chain(self, nodes: Iterable[Node]): |
| 269 | """ |