upgrade_db function always uses schema version defined internally

illinois-ceesd · Dec 17, 2023 · 80d74af · 80d74af
1 parent 0e64ec0
commit 80d74af
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/logpyle/upgrade_db.py b/logpyle/upgrade_db.py
@@ -78,9 +78,10 @@ def upgrade_conn(conn: sqlite3.Connection) -> sqlite3.Connection:
     schema_version = 3
     value = bytes(dumps(schema_version))
     if gathered:
-        conn.execute("UPDATE runs SET schema_version=3")
+        conn.execute("UPDATE runs SET schema_version=?",
+                     (schema_version,))
     else:
-        conn.execute("UPDATE constants SET value = ? WHERE name='schema_version'",
+        conn.execute("UPDATE constants SET value=? WHERE name='schema_version'",
                      (value,))
 
     return conn