Merge remote-tracking branch 'upstream/main' into pysdk_1

Ami11111 · Sep 6, 2024 · f1d4ac5 · f1d4ac5
2 parents 2c6e42c + 2712aa9
commit f1d4ac5
Show file tree

Hide file tree

Showing 13 changed files with 58 additions and 4 deletions.
diff --git a/example/delete_update_data.py b/example/delete_update_data.py
@@ -17,6 +17,7 @@
 '''
 
 import infinity
+import sys
 
 try:
     # open a local directory to store the data
@@ -39,6 +40,7 @@
     })
 
     # Insert 3 rows of data into the 'my_table'
+    print('about to insert data')
     table_instance.insert(
         [
             {
@@ -61,9 +63,11 @@
 
     result = table_instance.output(["num", "body"]).to_pl()
     print(result)
+    print('about to delete data')
     table_instance.delete("num = 2")
     result = table_instance.output(["num", "body"]).to_pl()
     print(result)
+    print('about to insert data again')
     table_instance.insert([
         {
             "num": 2,
@@ -79,11 +83,15 @@
     result = table_instance.output(["num", "body"]).to_pl()
     print(result)
 
-    table_instance.update("num = 2", [{"body": "unnecessary and harmful", "vec": [14.0, 7.2, 0.8, 10.9]}])
+    print('about to update data')
+    table_instance.update("num = 2", {"body": "unnecessary and harmful", "vec": [14.0, 7.2, 0.8, 10.9]})
     result = table_instance.output(["*"]).to_pl()
     print(result)
 
     infinity_instance.disconnect()
+    print('test done')
+    sys.exit(0)
 
 except Exception as e:
     print(str(e))
+    sys.exit(-1)
diff --git a/example/export_data.py b/example/export_data.py
@@ -18,6 +18,7 @@
 
 import infinity
 import os
+import sys
 
 current_path = os.path.abspath(__file__)
 project_directory = os.path.dirname(current_path)
@@ -115,6 +116,9 @@
 
 
     infinity_instance.disconnect()
+    print('test done')
+    sys.exit(0)
 
 except Exception as e:
-    print(str(e))
+    print(str(e))
+    sys.exit(-1)
diff --git a/example/filter_data.py b/example/filter_data.py
@@ -14,7 +14,7 @@
 
 
 import infinity
-from infinity.common import ConflictType, LOCAL_HOST
+import sys
 
 try:
     # Open a local directory to store the data
@@ -96,5 +96,8 @@
     print(result)
     infinity_instance.disconnect()
 
+    print('test done')
+    sys.exit(0)
 except Exception as e:
     print(str(e))
+    sys.exit(-1)
diff --git a/example/fulltext_search.py b/example/fulltext_search.py
@@ -17,6 +17,7 @@
 """
 
 import infinity
+import sys
 
 try:
     # open a local directory to store the data
@@ -94,5 +95,8 @@
 
     infinity_instance.disconnect()
 
+    print('test done')
+    sys.exit(0)
 except Exception as e:
     print(str(e))
+    sys.exit(-1)
diff --git a/example/fulltext_search_zh.py b/example/fulltext_search_zh.py
@@ -17,6 +17,7 @@
 """
 
 import infinity
+import sys
 
 """
 Checkout https://github.com/infiniflow/resource.git under /var/infinity (defined by 'resource_dir' of config file). The jieba dict is
@@ -117,5 +118,8 @@
 
     infinity_instance.disconnect()
 
+    print('test done')
+    sys.exit(0)
 except Exception as e:
     print(str(e))
+    sys.exit(-1)
diff --git a/example/hybrid_search.py b/example/hybrid_search.py
@@ -18,6 +18,7 @@
 
 import infinity
 from infinity.common import SparseVector
+import sys
 
 try:
     # open a local directory to store the data
@@ -113,5 +114,8 @@
     print(result)
     infinity_instance.disconnect()
 
+    print('test done')
+    sys.exit(0)
 except Exception as e:
     print(str(e))
+    sys.exit(-1)
diff --git a/example/import_data.py b/example/import_data.py
@@ -18,6 +18,7 @@
 
 import infinity
 import os
+import sys
 
 current_path = os.path.abspath(__file__)
 project_directory = os.path.dirname(current_path)
@@ -50,5 +51,8 @@
 
     infinity_instance.disconnect()
 
+    print('test done')
+    sys.exit(0)
 except Exception as e:
     print(str(e))
+    sys.exit(-1)
diff --git a/example/list_db_tables.py b/example/list_db_tables.py
@@ -17,6 +17,7 @@
 '''
 
 import infinity
+import sys
 
 try:
     # open a local directory to store the data
@@ -81,5 +82,8 @@
 
     infinity_instance.disconnect()
 
+    print('test done')
+    sys.exit(0)
 except Exception as e:
     print(str(e))
+    sys.exit(-1)
diff --git a/example/secondary_index.py b/example/secondary_index.py
@@ -18,6 +18,7 @@
 
 import infinity
 import time
+import sys
 
 from infinity import index
 
@@ -60,5 +61,8 @@
 
     infinity_instance.disconnect()
 
+    print('test done')
+    sys.exit(0)
 except Exception as e:
     print(str(e))
+    sys.exit(-1)
diff --git a/example/simple_example.py b/example/simple_example.py
@@ -17,6 +17,7 @@
 '''
 
 import infinity
+import sys
 
 try:
     # open a local directory to store the data
@@ -64,5 +65,8 @@
 
     infinity_instance.disconnect()
 
+    print('test done')
+    sys.exit(0)
 except Exception as e:
     print(str(e))
+    sys.exit(-1)
diff --git a/example/sparse_vector_search.py b/example/sparse_vector_search.py
@@ -18,6 +18,7 @@
 
 import infinity
 from infinity.common import SparseVector
+import sys
 
 try:
     # open a local directory to store the data
@@ -64,5 +65,8 @@
     print(result)
     infinity_instance.disconnect()
 
+    print('test done')
+    sys.exit(0)
 except Exception as e:
     print(str(e))
+    sys.exit(-1)
diff --git a/example/tensor_search.py b/example/tensor_search.py
@@ -14,7 +14,7 @@
 
 
 import infinity
-from infinity.common import ConflictType, LOCAL_HOST
+import sys
 
 try:
     # Open a local directory to store the data
@@ -67,5 +67,8 @@
     print(result)
     infinity_instance.disconnect()
 
+    print('test done')
+    sys.exit(0)
 except Exception as e:
     print(str(e))
+    sys.exit(-1)
diff --git a/example/vector_search.py b/example/vector_search.py
@@ -17,6 +17,7 @@
 '''
 
 import infinity
+import sys
 
 try:
     # open a local directory to store the data
@@ -64,5 +65,8 @@
     print(result)
     infinity_instance.disconnect()
 
+    print('test done')
+    sys.exit(0)
 except Exception as e:
     print(str(e))
+    sys.exit(-1)