From 28c2d24931ebd592ad2e98d599448bcf388e4593 Mon Sep 17 00:00:00 2001
From: Pekka Enberg <penberg@iki.fi>
Date: Tue, 24 Jun 2025 15:47:21 +0300
Subject: [PATCH] antithesis: Relax connect failure check
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

We also want to just ignore this under Antithesis:

``´
limbo.DatabaseError: Failed to open database: LockingError("Failed locking file. File is locked by another process")
```
---
 antithesis-tests/stress-composer/parallel_driver_delete.py      | 2 +-
 antithesis-tests/stress-composer/parallel_driver_insert.py      | 2 +-
 .../stress-composer/parallel_driver_integritycheck.py           | 2 +-
 antithesis-tests/stress-composer/parallel_driver_update.py      | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/antithesis-tests/stress-composer/parallel_driver_delete.py b/antithesis-tests/stress-composer/parallel_driver_delete.py
index 47857c4e2..52e6645c5 100755
--- a/antithesis-tests/stress-composer/parallel_driver_delete.py
+++ b/antithesis-tests/stress-composer/parallel_driver_delete.py
@@ -26,7 +26,7 @@ cols = [f"col_{col}" for col in range(tbl_schema["colCount"]) if col != pk]
 
 try:
     con = limbo.connect("stress_composer.db")
-except limbo.OperationalError as e:
+except Exception as e:
     print(f"Failed to open stress_composer.db. Exiting... {e}")
     exit(0)
 cur = con.cursor()
diff --git a/antithesis-tests/stress-composer/parallel_driver_insert.py b/antithesis-tests/stress-composer/parallel_driver_insert.py
index e1d273eb8..7e7f2cccd 100755
--- a/antithesis-tests/stress-composer/parallel_driver_insert.py
+++ b/antithesis-tests/stress-composer/parallel_driver_insert.py
@@ -22,7 +22,7 @@ cols = ", ".join([f"col_{col}" for col in range(tbl_schema["colCount"])])
 
 try:
     con = limbo.connect("stress_composer.db")
-except limbo.OperationalError as e:
+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 62fcc49ac..e375fea29 100755
--- a/antithesis-tests/stress-composer/parallel_driver_integritycheck.py
+++ b/antithesis-tests/stress-composer/parallel_driver_integritycheck.py
@@ -22,7 +22,7 @@ cols = ", ".join([f"col_{col}" for col in range(tbl_schema["colCount"])])
 
 try:
     con = limbo.connect("stress_composer.db")
-except limbo.OperationalError as e:
+except Exception as e:
     print(f"Failed to open stress_composer.db. Exiting... {e}")
     exit(0)
 cur = con.cursor()
diff --git a/antithesis-tests/stress-composer/parallel_driver_update.py b/antithesis-tests/stress-composer/parallel_driver_update.py
index 14a02efde..200333147 100755
--- a/antithesis-tests/stress-composer/parallel_driver_update.py
+++ b/antithesis-tests/stress-composer/parallel_driver_update.py
@@ -26,7 +26,7 @@ cols = [f"col_{col}" for col in range(tbl_schema["colCount"]) if col != pk]
 # print(cols)
 try:
     con = limbo.connect("stress_composer.db")
-except limbo.OperationalError as e:
+except Exception as e:
     print(f"Failed to open stress_composer.db. Exiting... {e}")
     exit(0)
 cur = con.cursor()