(self, seq, op_result: op_def_pb2.OpResult)
| 133 | return app |
| 134 | |
| 135 | def _rebuild_context(self, seq, op_result: op_def_pb2.OpResult): |
| 136 | from graphscope.framework.context import Context |
| 137 | |
| 138 | # get context dag node as base |
| 139 | context_dag_node = self._fetches[seq] |
| 140 | ret = json.loads(op_result.result.decode("utf-8", errors="ignore")) |
| 141 | context_type = ret["context_type"] |
| 142 | if context_type == "dynamic_vertex_data": |
| 143 | # for nx |
| 144 | from graphscope.framework.context import DynamicVertexDataContext |
| 145 | |
| 146 | return DynamicVertexDataContext(context_dag_node, ret["context_key"]) |
| 147 | return Context(context_dag_node, ret["context_key"], ret["context_schema"]) |
| 148 | |
| 149 | def wrap_results(self, response: message_pb2.RunStepResponse): # noqa: C901 |
| 150 | rets = list() |
no test coverage detected