diff options
author | Frederick Muriuki Muriithi | 2025-05-19 15:46:13 -0500 |
---|---|---|
committer | Frederick Muriuki Muriithi | 2025-05-19 15:46:13 -0500 |
commit | 72ee14772f1567b5410a2c907ad0dfab7a8e4670 (patch) | |
tree | 6664dd1ca33ecd286657666740f81a52c4473148 | |
parent | c93c63ee8464a41cdea5640eb4d1f8a451b62550 (diff) | |
download | gn-uploader-72ee14772f1567b5410a2c907ad0dfab7a8e4670.tar.gz |
Bug: Connection objects do not have execute() function.
-rw-r--r-- | scripts/load_phenotypes_to_db.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/scripts/load_phenotypes_to_db.py b/scripts/load_phenotypes_to_db.py index 9721263..c034212 100644 --- a/scripts/load_phenotypes_to_db.py +++ b/scripts/load_phenotypes_to_db.py @@ -305,6 +305,7 @@ if __name__ == "__main__": setup_logging(args.log_level.upper()) with (mysqldb.database_connection(args.db_uri) as conn, + conn.cursor(cursorclass=DictCursor) as cursor, sqlite3.connection(args.jobs_db_path) as jobs_conn): # Lock the PublishXRef/PublishData/PublishSE/NStrain here: Why? # The `DataId` values are sequential, but not auto-increment @@ -320,7 +321,7 @@ if __name__ == "__main__": "PublishData", "PublishSE", "NStrain") - conn.execute(# Lock the tables to avoid race conditions + cursor.execute(# Lock the tables to avoid race conditions "LOCK TABLES " "PublishXRef WRITE, " "PublishData WRITE, " @@ -336,7 +337,7 @@ if __name__ == "__main__": stack_info=True) logger.debug("Unlocking all database tables.") - conn.execute("UNLOCK TABLES") + cursor.execute("UNLOCK TABLES") return 1 |