Skip to content

Commit

Permalink
more debugging
Browse files Browse the repository at this point in the history
  • Loading branch information
jmmcatee committed Sep 26, 2019
1 parent 1a8b333 commit 50ee027
Showing 1 changed file with 7 additions and 0 deletions.
7 changes: 7 additions & 0 deletions common/queue/queue.go
Original file line number Diff line number Diff line change
Expand Up @@ -1121,6 +1121,13 @@ func (q *Queue) updateQueue() {
jobStatus := common.RPCCall{Job: jobs[i]}
var retJob common.Job

log.WithFields(log.Fields{
"uuid": jobs[i].UUID,
"name": jobs[i].Name,
"status": jobs[i].Status,
"resuuid": jobs[i].ResAssigned,
"client": q.pool[jobs[i].ResAssigned].Client,
}).Debug("RPC call for task status")
err := q.pool[jobs[i].ResAssigned].Client.Call("Queue.TaskStatus", jobStatus, &retJob)
// we care about the errors, but only from a logging perspective
if err != nil {
Expand Down

0 comments on commit 50ee027

Please sign in to comment.