fix scan cursor (#201)

vesoft-inc · Feb 21, 2022 · cec1f47 · cec1f47
1 parent 37ba36b
commit cec1f47
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git 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
@@ -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(