Fix bug that caused failures to not be logged.

benmanns · Jul 3, 2014 · 0ea6ffb · 0ea6ffb
1 parent ed77c6c
commit 0ea6ffb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/worker.go b/worker.go
@@ -125,8 +125,8 @@ func (w *worker) work(jobs <-chan *job, monitor *sync.WaitGroup) {
 func (w *worker) run(job *job, workerFunc workerFunc) {
 	var err error
 	defer func() {
-		conn, err := GetConn()
-		if err != nil {
+		conn, errCon := GetConn()
+		if errCon != nil {
 			logger.Criticalf("Error on getting connection in worker %v", w)
 		} else {
 			w.finish(conn, job, err)