about summary refs log tree commit diff
path: root/gn_libs/jobs/migrations.py
diff options
context:
space:
mode:
authorFrederick Muriuki Muriithi2025-06-11 03:32:24 -0500
committerFrederick Muriuki Muriithi2025-06-11 03:32:24 -0500
commitade102b0b9983c4f63b2f819a9884919ce00e405 (patch)
treea7a485a87851a606fafa668e3a23ce751e148ab2 /gn_libs/jobs/migrations.py
parentea61d349cc6368c13c22e8b23189ae53180b124a (diff)
downloadgn-libs-ade102b0b9983c4f63b2f819a9884919ce00e405.tar.gz
Fix code errors caught by linter.
Diffstat (limited to 'gn_libs/jobs/migrations.py')
-rw-r--r--gn_libs/jobs/migrations.py5
1 files changed, 3 insertions, 2 deletions
diff --git a/gn_libs/jobs/migrations.py b/gn_libs/jobs/migrations.py
index 86fb958..0c9825b 100644
--- a/gn_libs/jobs/migrations.py
+++ b/gn_libs/jobs/migrations.py
@@ -1,6 +1,6 @@
 """Database migrations for the jobs to ensure consistency downstream."""
 from gn_libs.protocols import DbCursor
-from gn_libs.sqlite3 import cursor, connection
+from gn_libs.sqlite3 import connection, cursor as acquire_cursor
 
 def __create_table_jobs__(cursor: DbCursor):
     """Create the jobs table"""
@@ -61,8 +61,9 @@ def __create_table_jobs_output_streams__(cursor: DbCursor):
 
 
 def run_migrations(sqlite_url: str):
+    """Run the migrations to setup the background jobs database."""
     with (connection(sqlite_url) as conn,
-          cursor(conn) as curr):
+          acquire_cursor(conn) as curr):
         __create_table_jobs__(curr)
         __create_table_jobs_metadata__(curr)
         __create_table_jobs_output_streams__(curr)