bug fix for double starts

jmmcatee · Oct 2, 2019 · 4d71ef5 · 4d71ef5
1 parent 97c216e
commit 4d71ef5
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 0 deletions.
diff --git a/common/queue/queue.go b/common/queue/queue.go
@@ -964,6 +964,10 @@ func (q *Queue) keeper() {
 								}).Debug("Found empty resource hardware")
 
 								// This resource is free, so lets find a job for it
+								jobs, err := q.db.GetAllJobs()
+								if err != nil {
+									log.Error(err)
+								}
 							JobLoop:
 								for jobKey := range jobs {
 									logger := log.WithFields(log.Fields{

diff --git a/common/queue/stack.go b/common/queue/stack.go
@@ -231,6 +231,7 @@ func (db *JobDB) UpdateJob(j common.Job) error {
 	logger := log.WithFields(log.Fields{
 		"uuid":   j.UUID,
 		"name":   j.Name,
+		"status": j.Status,
 		"resid":  j.ResAssigned,
 		"params": common.CleanJobParamsForLogging(j),
 	})

diff --git a/common/queue/test.db b/common/queue/test.db