diff --git a/example/ScanVertexEdgeExample.py b/example/ScanVertexEdgeExample.py index d68302ec..7efc893d 100644 --- a/example/ScanVertexEdgeExample.py +++ b/example/ScanVertexEdgeExample.py @@ -57,7 +57,7 @@ def prepare_data(): def scan_person_vertex(graph_storage_client): resp = graph_storage_client.scan_vertex( - space_name='ScanSpace', tag_name='person', limit=100 + space_name='ScanSpace', tag_name='person', limit=1 ) print('======== Scan vertexes in ScanSpace ======') while resp.has_next(): diff --git a/nebula3/sclient/__init__.py b/nebula3/sclient/__init__.py index ab4cf0c6..9d0d4055 100644 --- a/nebula3/sclient/__init__.py +++ b/nebula3/sclient/__init__.py @@ -192,6 +192,7 @@ def do_scan_job( part_info.has_done = True cursor = parts[part_info.part_id] resp_cursor = resp.cursors[part_info.part_id] + part_info.cursor = cursor if resp_cursor.next_cursor: cursor.next_cursor = resp_cursor.next_cursor logger.debug(