1 files changed, 3 insertions, 2 deletions
diff --git a/utils/submit-grid-jobs b/utils/submit-grid-jobs
index dd44d14..3129532 100755
--- a/utils/submit-grid-jobs
+++ b/utils/submit-grid-jobs
@@ -480,7 +480,7 @@ def get_njobs():
 def main(conn, dqxx_dir, max_retries, max_jobs):
     c = conn.cursor()
 
-    results = c.execute('SELECT id, filename, run, uuid, gtid, particle_id, max_time, state, nretry, submit_file FROM state')
+    results = c.execute('SELECT id, filename, run, uuid, gtid, particle_id, max_time, state, nretry, submit_file FROM state ORDER BY priority DESC, timestamp ASC')
 
     njobs = get_njobs()
 
@@ -635,7 +635,8 @@ if __name__ == '__main__':
         "nretry         INTEGER,"
         "submit_file    TEXT,"
         "max_time       REAL NOT NULL,"
-        "message        TEXT)"
+        "message        TEXT,"
+        "priority       INTEGER DEFAULT 1)"
     )
 
     conn.commit()