aljaz/turso
1
0
Fork 0
mirror of https://github.com/aljazceru/turso.git synced 2025-12-18 17:14:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

antithesis-tests: Enable indexes in Antithesis parallel drivers

Browse Source
This commit is contained in:
Pekka Enberg
2025-07-21 12:48:43 +03:00
parent 993079e39d
commit 0ebe6bb933
7 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
antithesis-tests/stress-composer/first_setup.py
View File

@@ -35,7 +35,7 @@ cur_init.execute("CREATE TABLE schemas (schema TEXT, tbl INT)")
cur_init.execute("CREATE TABLE tables (count INT)") cur_init.execute("CREATE TABLE tables (count INT)")
try: try:
con = turso.connect("stress_composer.db") con = turso.connect("stress_composer.db", experimental_indexes=True)
except Exception as e: except Exception as e:
print(f"Error connecting to database: {e}") print(f"Error connecting to database: {e}")
exit(0) exit(0)

2
antithesis-tests/stress-composer/parallel_driver_delete.py
View File

@@ -25,7 +25,7 @@ pk = tbl_schema["pk"]
cols = [f"col_{col}" for col in range(tbl_schema["colCount"]) if col != pk] cols = [f"col_{col}" for col in range(tbl_schema["colCount"]) if col != pk]
try: try:
con = turso.connect("stress_composer.db") con = turso.connect("stress_composer.db", experimental_indexes=True)
except Exception as e: except Exception as e:
print(f"Failed to open stress_composer.db. Exiting... {e}") print(f"Failed to open stress_composer.db. Exiting... {e}")
exit(0) exit(0)

2
antithesis-tests/stress-composer/parallel_driver_insert.py
View File

@@ -21,7 +21,7 @@ tbl_schema = json.loads(cur_init.execute(f"SELECT schema FROM schemas WHERE tbl
cols = ", ".join([f"col_{col}" for col in range(tbl_schema["colCount"])]) cols = ", ".join([f"col_{col}" for col in range(tbl_schema["colCount"])])
try: try:
con = turso.connect("stress_composer.db") con = turso.connect("stress_composer.db", experimental_indexes=True)
except Exception as e: except Exception as e:
print(f"Failed to open stress_composer.db. Exiting... {e}") print(f"Failed to open stress_composer.db. Exiting... {e}")
exit(0) exit(0)

2
antithesis-tests/stress-composer/parallel_driver_integritycheck.py
View File

@@ -21,7 +21,7 @@ tbl_schema = json.loads(cur_init.execute(f"SELECT schema FROM schemas WHERE tbl
cols = ", ".join([f"col_{col}" for col in range(tbl_schema["colCount"])]) cols = ", ".join([f"col_{col}" for col in range(tbl_schema["colCount"])])
try: try:
con = turso.connect("stress_composer.db") con = turso.connect("stress_composer.db", experimental_indexes=True)
except Exception as e: except Exception as e:
print(f"Failed to open stress_composer.db. Exiting... {e}") print(f"Failed to open stress_composer.db. Exiting... {e}")
exit(0) exit(0)

2
antithesis-tests/stress-composer/parallel_driver_rollback.py
View File

@@ -21,7 +21,7 @@ tbl_schema = json.loads(cur_init.execute(f"SELECT schema FROM schemas WHERE tbl
cols = ", ".join([f"col_{col}" for col in range(tbl_schema["colCount"])]) cols = ", ".join([f"col_{col}" for col in range(tbl_schema["colCount"])])
try: try:
con = turso.connect("stress_composer.db") con = turso.connect("stress_composer.db", experimental_indexes=True)
except Exception as e: except Exception as e:
print(f"Failed to open stress_composer.db. Exiting... {e}") print(f"Failed to open stress_composer.db. Exiting... {e}")
exit(0) exit(0)

2
antithesis-tests/stress-composer/parallel_driver_schema_rollback.py
View File

@@ -22,7 +22,7 @@ tbl_schema = json.loads(cur_init.execute(f"SELECT schema FROM schemas WHERE tbl
tbl_name = f"tbl_{selected_tbl}" tbl_name = f"tbl_{selected_tbl}"
try: try:
con = turso.connect("stress_composer.db") con = turso.connect("stress_composer.db", experimental_indexes=True)
except Exception as e: except Exception as e:
print(f"Failed to open stress_composer.db. Exiting... {e}") print(f"Failed to open stress_composer.db. Exiting... {e}")
exit(0) exit(0)

2
antithesis-tests/stress-composer/parallel_driver_update.py
View File

@@ -25,7 +25,7 @@ pk = tbl_schema["pk"]
cols = [f"col_{col}" for col in range(tbl_schema["colCount"]) if col != pk] cols = [f"col_{col}" for col in range(tbl_schema["colCount"]) if col != pk]
# print(cols) # print(cols)
try: try:
con = turso.connect("stress_composer.db") con = turso.connect("stress_composer.db", experimental_indexes=True)
except Exception as e: except Exception as e:
print(f"Failed to open stress_composer.db. Exiting... {e}") print(f"Failed to open stress_composer.db. Exiting... {e}")
exit(0) exit(0)