From 57e5b79011dcd3fd88f5b3c889551ea895a96e5c Mon Sep 17 00:00:00 2001 From: Nicolas Carlier Date: Sat, 1 Feb 2020 08:48:43 +0000 Subject: [PATCH] fix(): remove "done" statement at execution end --- pkg/worker/dispatcher.go | 2 +- pkg/worker/worker.go | 2 -- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/pkg/worker/dispatcher.go b/pkg/worker/dispatcher.go index 16f636c..bafd157 100644 --- a/pkg/worker/dispatcher.go +++ b/pkg/worker/dispatcher.go @@ -5,7 +5,7 @@ import ( "github.com/ncarlier/webhookd/pkg/model" ) -// WorkerQueue is the gloabl queue of Workers +// WorkerQueue is the global queue of Workers var WorkerQueue chan chan model.WorkRequest // WorkQueue is the global queue of work to dispatch diff --git a/pkg/worker/worker.go b/pkg/worker/worker.go index 297da66..73ef3bc 100644 --- a/pkg/worker/worker.go +++ b/pkg/worker/worker.go @@ -49,8 +49,6 @@ func (w Worker) Start() { if err != nil { metric.RequestsFailed.Add(1) work.MessageChan <- []byte(fmt.Sprintf("error: %s", err.Error())) - } else { - work.MessageChan <- []byte("done") } // Send notification notification.Notify(&work)