(self, seq, op_result: op_def_pb2.OpResult)
| 124 | return g |
| 125 | |
| 126 | def _rebuild_app(self, seq, op_result: op_def_pb2.OpResult): |
| 127 | from graphscope.framework.app import App |
| 128 | |
| 129 | # get app dag node as base |
| 130 | app_dag_node = self._fetches[seq] |
| 131 | # construct app |
| 132 | app = App(app_dag_node, op_result.result.decode("utf-8", errors="ignore")) |
| 133 | return app |
| 134 | |
| 135 | def _rebuild_context(self, seq, op_result: op_def_pb2.OpResult): |
| 136 | from graphscope.framework.context import Context |
no test coverage detected