diff --git a/jobs/avatars/avatars.go b/jobs/avatars/avatars.go
index 58865834..c22c9377 100644
--- a/jobs/avatars/avatars.go
+++ b/jobs/avatars/avatars.go
@@ -110,6 +110,7 @@ func StartWorkers(queue chan *arn.User, work func(*arn.User)) {
 		go func() {
 			for user := range queue {
 				work(user)
+				wg.Done()
 			}
 		}()
 	}