summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--manager/manager.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/manager/manager.go b/manager/manager.go
index 2a58aab..30c20a6 100644
--- a/manager/manager.go
+++ b/manager/manager.go
@@ -28,17 +28,17 @@ func (m *Manager) Run() {
wg.Add(1)
go func(w *work.Work) {
+ defer wg.Done()
nw := m.Filter.Filter(w)
err := nw.Error()
if err != nil {
fmt.Printf("Got an error when filtering Work: %q\n", err)
+ return
}
err = m.Output.Output(nw)
if err != nil {
fmt.Printf("Got an error when outputting Work: %q\n", err)
}
-
- wg.Done()
}(w)
}