fix: race condition in worker waitgroup

2026-05-06 23:18:32 +02:00
parent d7db3d6d1c
commit 7512aac53e
1 changed files with 1 additions and 1 deletions
--- 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)