From 0cb2833d7210bd6e4ce492a3525ee74dc2057aac Mon Sep 17 00:00:00 2001
From: Frederick Muriuki Muriithi
Date: Tue, 10 Jun 2025 17:01:16 -0500
Subject: Pass on the publication to the next job.

---
 scripts/load_phenotypes_to_db.py | 2 +-
 uploader/phenotypes/views.py     | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/scripts/load_phenotypes_to_db.py b/scripts/load_phenotypes_to_db.py
index 8339ea9..8f49e10 100644
--- a/scripts/load_phenotypes_to_db.py
+++ b/scripts/load_phenotypes_to_db.py
@@ -358,7 +358,7 @@ def load_data(conn: mysqldb.Connection, job: dict) -> int:
         int(_job_metadata["dataset_id"]))
     # 1. Just retrive the publication: Don't create publications for now.
     _publication = fetch_publication_by_id(
-        conn, int(_job_metadata.get("publicationid", "0"))) or {"Id": 0}
+        conn, int(_job_metadata.get("publication_id", "0"))) or {"Id": 0}
     # 2. Save all new phenotypes:
     #     -> return phenotype IDs
     bundle = Path(_job_metadata["bundle_file"])
diff --git a/uploader/phenotypes/views.py b/uploader/phenotypes/views.py
index 65d9371..82b46ff 100644
--- a/uploader/phenotypes/views.py
+++ b/uploader/phenotypes/views.py
@@ -709,6 +709,7 @@ def load_data_to_database(
                     "population_id": population["Id"],
                     "dataset_id": dataset["Id"],
                     "bundle_file": _meta["bundle"],
+                    "publication_id": _meta["publicationid"],
                     "authserver": oauth2client.authserver_uri(),
                     "token": token["access_token"],
                     "success_handler": (
-- 
cgit v1.2.3