Change Output interface to return an error

1 files changed, 5 insertions, 2 deletions

diff --git a/manager.go b/manager.go
index 3fd2234..0eeb51f 100644
--- a/manager.go
+++ b/manager.go
@@ -27,9 +27,12 @@ func (m *Manager) Run() {
 			nw := m.Filter.Filter(w)
 			err := nw.Error()
 			if err != nil {
-				fmt.Printf("Got an error when processing Work: %q\n", err)
+				fmt.Printf("Got an error when filtering Work: %q\n", err)
+			}
+			err = m.Output.Output(nw)
+			if err != nil {
+				fmt.Printf("Got an error when outputting Work: %q\n", err)
 			}
-			m.Output.Output(nw)
 
 			wg.Done()
 		}(w)