summaryrefslogtreecommitdiff
path: root/manager.go
diff options
context:
space:
mode:
Diffstat (limited to 'manager.go')
-rw-r--r--manager.go4
1 files changed, 4 insertions, 0 deletions
diff --git a/manager.go b/manager.go
index 0eeb51f..d3d38fd 100644
--- a/manager.go
+++ b/manager.go
@@ -21,6 +21,10 @@ func (m *Manager) Run() {
ic := m.Input.Start()
for w := range ic {
+ if w.Err != nil {
+ fmt.Printf("Got an error when getting Work input: %q\n", w.Err)
+ continue
+ }
wg.Add(1)
go func(w *work.Work) {