diff --git a/antithesis-tests/stress-composer/first_setup.py b/antithesis-tests/stress-composer/first_setup.py index c3a3c8351..50a5f73b4 100755 --- a/antithesis-tests/stress-composer/first_setup.py +++ b/antithesis-tests/stress-composer/first_setup.py @@ -35,7 +35,7 @@ cur_init.execute("CREATE TABLE schemas (schema TEXT, tbl INT)") cur_init.execute("CREATE TABLE tables (count INT)") try: - con = turso.connect("stress_composer.db") + con = turso.connect("stress_composer.db", experimental_indexes=True) except Exception as e: print(f"Error connecting to database: {e}") exit(0) diff --git a/antithesis-tests/stress-composer/parallel_driver_delete.py b/antithesis-tests/stress-composer/parallel_driver_delete.py index d2e719fec..1fcb42cd7 100755 --- a/antithesis-tests/stress-composer/parallel_driver_delete.py +++ b/antithesis-tests/stress-composer/parallel_driver_delete.py @@ -25,7 +25,7 @@ pk = tbl_schema["pk"] cols = [f"col_{col}" for col in range(tbl_schema["colCount"]) if col != pk] try: - con = turso.connect("stress_composer.db") + con = turso.connect("stress_composer.db", experimental_indexes=True) except Exception as e: print(f"Failed to open stress_composer.db. Exiting... {e}") exit(0) diff --git a/antithesis-tests/stress-composer/parallel_driver_insert.py b/antithesis-tests/stress-composer/parallel_driver_insert.py index bb5a02170..685c98bc4 100755 --- a/antithesis-tests/stress-composer/parallel_driver_insert.py +++ b/antithesis-tests/stress-composer/parallel_driver_insert.py @@ -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"])]) try: - con = turso.connect("stress_composer.db") + con = turso.connect("stress_composer.db", experimental_indexes=True) except Exception as e: print(f"Failed to open stress_composer.db. Exiting... {e}") exit(0) diff --git a/antithesis-tests/stress-composer/parallel_driver_integritycheck.py b/antithesis-tests/stress-composer/parallel_driver_integritycheck.py index f19226b56..ff608676f 100755 --- a/antithesis-tests/stress-composer/parallel_driver_integritycheck.py +++ b/antithesis-tests/stress-composer/parallel_driver_integritycheck.py @@ -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"])]) try: - con = turso.connect("stress_composer.db") + con = turso.connect("stress_composer.db", experimental_indexes=True) except Exception as e: print(f"Failed to open stress_composer.db. Exiting... {e}") exit(0) diff --git a/antithesis-tests/stress-composer/parallel_driver_rollback.py b/antithesis-tests/stress-composer/parallel_driver_rollback.py index 9dc3f284e..f730f1041 100755 --- a/antithesis-tests/stress-composer/parallel_driver_rollback.py +++ b/antithesis-tests/stress-composer/parallel_driver_rollback.py @@ -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"])]) try: - con = turso.connect("stress_composer.db") + con = turso.connect("stress_composer.db", experimental_indexes=True) except Exception as e: print(f"Failed to open stress_composer.db. Exiting... {e}") exit(0) diff --git a/antithesis-tests/stress-composer/parallel_driver_schema_rollback.py b/antithesis-tests/stress-composer/parallel_driver_schema_rollback.py index 594925797..85ddb5cb3 100755 --- a/antithesis-tests/stress-composer/parallel_driver_schema_rollback.py +++ b/antithesis-tests/stress-composer/parallel_driver_schema_rollback.py @@ -22,7 +22,7 @@ tbl_schema = json.loads(cur_init.execute(f"SELECT schema FROM schemas WHERE tbl tbl_name = f"tbl_{selected_tbl}" try: - con = turso.connect("stress_composer.db") + con = turso.connect("stress_composer.db", experimental_indexes=True) except Exception as e: print(f"Failed to open stress_composer.db. Exiting... {e}") exit(0) diff --git a/antithesis-tests/stress-composer/parallel_driver_update.py b/antithesis-tests/stress-composer/parallel_driver_update.py index 101508cc2..50a65b6b6 100755 --- a/antithesis-tests/stress-composer/parallel_driver_update.py +++ b/antithesis-tests/stress-composer/parallel_driver_update.py @@ -25,7 +25,7 @@ pk = tbl_schema["pk"] cols = [f"col_{col}" for col in range(tbl_schema["colCount"]) if col != pk] # print(cols) try: - con = turso.connect("stress_composer.db") + con = turso.connect("stress_composer.db", experimental_indexes=True) except Exception as e: print(f"Failed to open stress_composer.db. Exiting... {e}") exit(0)