(self, seq, op_result: op_def_pb2.OpResult)
| 112 | return self._sub_dag |
| 113 | |
| 114 | def _rebuild_graph(self, seq, op_result: op_def_pb2.OpResult): |
| 115 | if isinstance(self._fetches[seq], Operation): |
| 116 | # for nx Graph |
| 117 | return op_result.graph_def |
| 118 | # get graph dag node as base |
| 119 | graph_dag_node = self._fetches[seq] |
| 120 | # construct graph |
| 121 | g = Graph(graph_dag_node) |
| 122 | # update graph flied from graph_def |
| 123 | g.update_from_graph_def(op_result.graph_def) |
| 124 | return g |
| 125 | |
| 126 | def _rebuild_app(self, seq, op_result: op_def_pb2.OpResult): |
| 127 | from graphscope.framework.app import App |
no test coverage detected