features/consolidated_misc.feature

@@ -1714,6 +1714,12 @@ Feature: Consolidated Misc
     And the temporary connection should be closed afterward
 
 
+  Scenario: get_current_revision uses check_same_thread=False for SQLite engines
+    Given a migration runner configured for "sqlite:///:memory:"
+    When I request the current revision from the database
+    Then the SQLite engine for get_current_revision should use check_same_thread=False
+
+
   Scenario: File-based SQLite database directory is created if missing
     Given a migration runner configured for "sqlite:///tmp/test-db/mydb.db"
     When I initialize or upgrade a file-based SQLite database

features/steps/migration_runner_steps.py

@@ -316,6 +316,17 @@ def step_then_temp_connection_closed(context) -> None:
     assert context.current_rev_fake_engine.connections[0].exit_called is True
 
 
+@then("the SQLite engine for get_current_revision should use check_same_thread=False")
+def step_then_get_current_revision_check_same_thread(context) -> None:
+    _url, kwargs = context.current_rev_create_call
+    assert "connect_args" in kwargs, (
+        "Expected connect_args to be passed to create_engine for SQLite"
+    )
+    assert kwargs["connect_args"].get("check_same_thread") is False, (
+        "Expected check_same_thread=False in connect_args for SQLite engine"
+    )
+
+
 @when("I initialize or upgrade a file-based SQLite database")
 def step_when_init_file_based_sqlite(context) -> None:
     import shutil

src/cleveragents/infrastructure/database/migration_runner.py

@@ -154,7 +154,13 @@ class MigrationRunner:
         Returns:
             Current revision ID or None if no migrations have been applied
         """
-        engine = create_engine(self.database_url)
+        if self.database_url.startswith("sqlite"):
+            engine = create_engine(
+                self.database_url,
+                connect_args={"check_same_thread": False},
+            )
+        else:
+            engine = create_engine(self.database_url)
         with engine.connect() as connection:
             context = MigrationContext.configure(connection)
             return context.get_current_revision()