From d4b7312423d5aef91b264bb21429e79ec65cec7c Mon Sep 17 00:00:00 2001
From: Frederick Muriuki Muriithi
Date: Tue, 25 Mar 2025 12:55:25 -0500
Subject: Update jobs database schema.

---
 gn_libs/jobs/migrations.py | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

(limited to 'gn_libs')

diff --git a/gn_libs/jobs/migrations.py b/gn_libs/jobs/migrations.py
index cc463e3..86fb958 100644
--- a/gn_libs/jobs/migrations.py
+++ b/gn_libs/jobs/migrations.py
@@ -38,13 +38,13 @@ def __create_table_jobs_output_streams__(cursor: DbCursor):
     cursor.execute(
         """
         CREATE TABLE IF NOT EXISTS jobs_standard_outputs(
-          job_id TEXT PRIMARY KEY,
+          job_id TEXT NOT NULL,
           output_stream TEXT,
-          timestamp TEXT,
           value TEXT,
           FOREIGN KEY(job_id) REFERENCES jobs(job_id)
             ON UPDATE CASCADE ON DELETE RESTRICT,
-          CHECK (output_stream IN ('stdout', 'stderr'))
+          CHECK (output_stream IN ('stdout', 'stderr')),
+          PRIMARY KEY(job_id, output_stream)
         ) WITHOUT ROWID
         """)
     cursor.execute(
-- 
cgit v1.2.3