slow down complete review refresh
This commit is contained in:
parent
0a8b4ca6c8
commit
a24ba03c8b
|
@ -51,7 +51,10 @@ func (w *Worker) RefreshAllReviews(jobID int) {
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, m := range movies {
|
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
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue