diff --git a/internal/worker/relations.go b/internal/worker/relations.go index e34d279..3165cbd 100644 --- a/internal/worker/relations.go +++ b/internal/worker/relations.go @@ -156,8 +156,8 @@ func (w *Worker) syncRelations(ctx context.Context) { var wg sync.WaitGroup for range workerCount { + wg.Add(1) go func() { - wg.Add(1) defer wg.Done() for a := range jobs { w.syncSingleAnime(ctx, a.ID)