darkkirb/harness-drone
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

add debug info to queue backup

Browse source
This commit is contained in:
Brad Rydzewski 2017-05-04 03:14:48 +02:00
parent 222bdd6854
commit 9c69e2a5e1
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
model/queue.go
View file

@ -3,6 +3,7 @@ package model
import ( import (
"context" "context"
"github.com/Sirupsen/logrus"
"github.com/cncd/queue" "github.com/cncd/queue"
) )
@ -55,8 +56,13 @@ func (q *persistentQueue) Push(c context.Context, task *queue.Task) error {
// Poll retrieves and removes a task head of this queue. // Poll retrieves and removes a task head of this queue.
func (q *persistentQueue) Poll(c context.Context, f queue.Filter) (*queue.Task, error) { func (q *persistentQueue) Poll(c context.Context, f queue.Filter) (*queue.Task, error) {
task, err := q.Queue.Poll(c, f) task, err := q.Queue.Poll(c, f)
if err == nil { if task != nil {
q.store.TaskDelete(task.ID) logrus.Debugf("pull queue item: %s: remove from backup", task.ID)
if derr := q.store.TaskDelete(task.ID); derr != nil {
logrus.Errorf("pull queue item: %s: failed to remove from backup: %s", task.ID, derr)
} else {
logrus.Errorf("pull queue item: %s: successfully removed from backup", task.ID)
}
} }
return task, err return task, err
} }