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