(self, source_node_id: str)
| 267 | return self._graph.edges.get((source_node_id, target_node_id)) |
| 268 | |
| 269 | async def get_node_edges(self, source_node_id: str): |
| 270 | if self._graph.has_node(source_node_id): |
| 271 | return list(self._graph.edges(source_node_id)) |
| 272 | return None |
| 273 | |
| 274 | async def upsert_node(self, node_id: str, node_data: dict[str, str]): |
| 275 | self._graph.add_node(node_id, **node_data) |