diff --git a/cmd/api-service/job/worker.go b/cmd/api-service/job/worker.go
index 8328469..13273e5 100644
--- a/cmd/api-service/job/worker.go
+++ b/cmd/api-service/job/worker.go
@@ -51,7 +51,10 @@ func (w *Worker) RefreshAllReviews(jobID int) {
 	}
 
 	for _, m := range movies {
-		w.RefreshReviews(jobID, m.ID)
+		if err := w.jq.Add(m.ID, ActionRefreshIMDBReviews); err != nil {
+			logger.Error("could not add job", "error", err)
+			return
+		}
 	}
 }