From 8bbbd120f6a1b7dd27e22a433b07326a41c32b04 Mon Sep 17 00:00:00 2001
From: Frederick Muriuki Muriithi
Date: Tue, 25 Mar 2025 13:20:57 -0500
Subject: Change query for updating metadata: allow creating new item.

---
 gn_libs/jobs/jobs.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

(limited to 'gn_libs')

diff --git a/gn_libs/jobs/jobs.py b/gn_libs/jobs/jobs.py
index 4519e4f..38cd9c0 100644
--- a/gn_libs/jobs/jobs.py
+++ b/gn_libs/jobs/jobs.py
@@ -132,7 +132,10 @@ def update_metadata(conn: DbConnection, job_id: Union[str, uuid.UUID], key: str,
     """Update the value of a metadata item."""
     with _cursor(conn) as cursor:
         cursor.execute(
-            "UPDATE jobs_metadata SET metadata_value=:value "
+            "INSERT INTO jobs_metadata(job_id, metadata_key, metadata_value) "
+            "VALUES (:job_id, :key, :value) "
+            "ON CONFLICT (job_id, metadata_key) DO UPDATE "
+            "SET metadata_value=:value "
             "WHERE job_id=:job_id AND metadata_key=:key",
             {
                 "job_id": str(job_id),
-- 
cgit v1.2.3