aboutsummaryrefslogtreecommitdiff
path: root/uploader/db_utils.py
diff options
context:
space:
mode:
authorFrederick Muriuki Muriithi2024-08-07 12:03:23 -0500
committerFrederick Muriuki Muriithi2024-08-07 12:03:23 -0500
commit91be84efe80891187a6cbb08bd0b5061ffb2613d (patch)
tree06b7e6bf8847b3bf95b962c494002b286c7feaea /uploader/db_utils.py
parentac319bc2b2ddb4a741169ff5913a785e432c7dd5 (diff)
downloadgn-uploader-91be84efe80891187a6cbb08bd0b5061ffb2613d.tar.gz
Make passing SQL_URI to `database_connection` mandatory.
Diffstat (limited to 'uploader/db_utils.py')
-rw-r--r--uploader/db_utils.py5
1 files changed, 2 insertions, 3 deletions
diff --git a/uploader/db_utils.py b/uploader/db_utils.py
index ef26398..357b3da 100644
--- a/uploader/db_utils.py
+++ b/uploader/db_utils.py
@@ -19,10 +19,9 @@ def parse_db_url(db_url) -> Tuple:
@contextlib.contextmanager
-def database_connection(db_url: Optional[str] = None) -> Iterator[mdb.Connection]:
+def database_connection(db_url: str) -> Iterator[mdb.Connection]:
"""function to create db connector"""
- host, user, passwd, db_name, db_port = parse_db_url(
- db_url or app.config["SQL_URI"])
+ host, user, passwd, db_name, db_port = parse_db_url(db_url)
connection = mdb.connect(
host, user, passwd, db_name, port=(db_port or 3306))
try: