diff options
| author | Frederick Muriuki Muriithi | 2025-03-25 13:20:24 -0500 |
|---|---|---|
| committer | Frederick Muriuki Muriithi | 2025-03-25 13:20:24 -0500 |
| commit | 8dc121fb4286f1bd90b51777d215253b2806ee43 (patch) | |
| tree | 2d414a3fb042afd1b1802c37ee29a7ad116f564c | |
| parent | 99baa9dfa6ba3d1abe4c472be747c3e5716cecd8 (diff) | |
| download | gn-libs-8dc121fb4286f1bd90b51777d215253b2806ee43.tar.gz | |
Add "WHERE" clause to avoid updating all rows.
| -rw-r--r-- | gn_libs/jobs/jobs.py | 3 |
1 files changed, 2 insertions, 1 deletions
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, |