aboutsummaryrefslogtreecommitdiff
path: root/uploader/publications
diff options
context:
space:
mode:
authorFrederick Muriuki Muriithi2025-04-14 09:37:14 -0500
committerFrederick Muriuki Muriithi2025-04-14 09:37:14 -0500
commitca10fd8f849b318a5f27e323620b19e66e08c99f (patch)
tree3abe79d1ff738554220869b59c31ed71344739a0 /uploader/publications
parentabec47486572fd1dcbbe48ea862b3e9006427aa2 (diff)
downloadgn-uploader-ca10fd8f849b318a5f27e323620b19e66e08c99f.tar.gz
Add types for connection objects.
Diffstat (limited to 'uploader/publications')
-rw-r--r--uploader/publications/models.py11
1 files changed, 9 insertions, 2 deletions
diff --git a/uploader/publications/models.py b/uploader/publications/models.py
index e7f197a..f36c800 100644
--- a/uploader/publications/models.py
+++ b/uploader/publications/models.py
@@ -1,7 +1,11 @@
"""Module to handle persistence and retrieval of publication to/from MariaDB"""
+from gn_libs.mysqldb import Connection
+
def fetch_phenotype_publications(
- conn, ids: tuple[tuple[int, int], ...]) -> tuple[dict, ...]:
+ conn: Connection,
+ ids: tuple[tuple[int, int], ...]
+) -> tuple[dict, ...]:
"""Fetch publication from database by ID."""
paramstr = ",".join(["(%s, %s)"] * len(ids))
query = (
@@ -15,7 +19,10 @@ def fetch_phenotype_publications(
return tuple(dict(row) for row in cursor.fetchall())
-def create_new_publications(conn, publications) -> dict:
+def create_new_publications(
+ conn: Connection,
+ publications: tuple[dict, ...]
+) -> tuple[dict, ...]:
if len(publications) > 0:
with conn.cursor(cursorclass=DictCursor) as cursor:
cursor.executemany(