(frag, context)
| 580 | |
| 581 | @staticmethod |
| 582 | def PEval(frag, context): |
| 583 | src = context.get_config(b"src") |
| 584 | graphscope.declare(graphscope.Vertex, source) |
| 585 | native_source = False |
| 586 | v_label_num = frag.vertex_label_num() |
| 587 | for v_label_id in range(v_label_num): |
| 588 | if frag.get_inner_node(v_label_id, src, source): |
| 589 | native_source = True |
| 590 | break |
| 591 | if native_source: |
| 592 | context.set_node_value(source, 0) |
| 593 | else: |
| 594 | return |
| 595 | e_label_num = frag.edge_label_num() |
| 596 | for e_label_id in range(e_label_num): |
| 597 | edges = frag.get_outgoing_edges(source, e_label_id) |
| 598 | for e in edges: |
| 599 | dst = e.neighbor() |
| 600 | distv = e.get_int(2) |
| 601 | if context.get_node_value(dst) > distv: |
| 602 | context.set_node_value(dst, distv) |
| 603 | |
| 604 | @staticmethod |
| 605 | def IncEval(frag, context): |
nothing calls this directly
no test coverage detected