Merge pull request #230 from jpwhite4/jobscript

Fix jobscript ingestion sql.
ubccr · Oct 9, 2020 · 4a2d606 · 4a2d606
2 parents 158d5fe + 7cb4429
commit 4a2d606
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/supremm/ingest_jobscripts.py b/src/supremm/ingest_jobscripts.py
@@ -47,8 +47,7 @@ def __init__(self, dwconfig, schema, timestamp_mode):
                             `modw`.`job_tasks`
                         WHERE
                             resource_id = %s 
-                            AND local_job_id_raw = %s
-                        ON DUPLICATE KEY UPDATE script = script"""
+                            AND local_job_id_raw = %s"""
 
             if self.timestamp_mode == 'start':
                 self.query += ' AND ABS(DATEDIFF(DATE(FROM_UNIXTIME(start_time_ts)), %s)) < 2'
@@ -59,6 +58,8 @@ def __init__(self, dwconfig, schema, timestamp_mode):
             #else
                 # self.timestamp_mode == 'None' which means no date restrictions
 
+            self.query += " ON DUPLICATE KEY UPDATE resource_id = VALUES(resource_id), start_date = VALUES(start_date), script = VALUES(script)"
+
         self.buffered = 0
 
     def insert(self, data):