diff options
author | Frederick Muriuki Muriithi | 2025-06-11 03:32:24 -0500 |
---|---|---|
committer | Frederick Muriuki Muriithi | 2025-06-11 03:32:24 -0500 |
commit | ade102b0b9983c4f63b2f819a9884919ce00e405 (patch) | |
tree | a7a485a87851a606fafa668e3a23ce751e148ab2 /gn_libs/jobs/migrations.py | |
parent | ea61d349cc6368c13c22e8b23189ae53180b124a (diff) | |
download | gn-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.py | 5 |
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) |