(self, key: str, node: NodeSpec)
| 462 | self.builder = builder |
| 463 | |
| 464 | def attach_node(self, key: str, node: NodeSpec) -> None: |
| 465 | self.channels[key] = EphemeralValue(Any) |
| 466 | self.nodes[key] = ( |
| 467 | PregelNode(channels=[], triggers=[], metadata=node.metadata) |
| 468 | | node.runnable |
| 469 | | ChannelWrite([ChannelWriteEntry(key)], tags=[TAG_HIDDEN]) |
| 470 | ) |
| 471 | cast(list[str], self.stream_channels).append(key) |
| 472 | |
| 473 | def attach_edge(self, start: str, end: str) -> None: |
| 474 | if end == END: |
no test coverage detected