diff options
| -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, |