diff options
| -rw-r--r-- | manager/manager.go | 4 |
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) } |