From 8dc121fb4286f1bd90b51777d215253b2806ee43 Mon Sep 17 00:00:00 2001
From: Frederick Muriuki Muriithi
Date: Tue, 25 Mar 2025 13:20:24 -0500
Subject: Add "WHERE" clause to avoid updating all rows.

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

diff --git a/gn_libs/jobs/jobs.py b/gn_libs/jobs/jobs.py
index a9cacbc..4519e4f 100644
--- a/gn_libs/jobs/jobs.py
+++ b/gn_libs/jobs/jobs.py
@@ -156,7 +156,8 @@ def push_to_stream(conn: DbConnection, job_id: Union[str, uuid.UUID], stream_nam
             "INSERT INTO jobs_standard_outputs(job_id, output_stream, value) "
             "VALUES(:job_id, :stream, :content) "
             "ON CONFLICT (job_id, output_stream) DO UPDATE "
-            "SET value=:content",
+            "SET value=:content "
+            "WHERE job_id=:job_id AND output_stream=:stream",
             {
                 "job_id": str(job_id),
                 "stream": stream_name,
-- 
cgit v1.2.3