Update jobs database schema.

1 files changed, 3 insertions, 3 deletions

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(