diff --git a/graphql/gqlgen/graph/schema.resolvers.go b/graphql/gqlgen/graph/schema.resolvers.go index bfca2b54..9a5cd2a8 100644 --- a/graphql/gqlgen/graph/schema.resolvers.go +++ b/graphql/gqlgen/graph/schema.resolvers.go @@ -84,12 +84,9 @@ func (r *queryResolver) Posts(ctx context.Context) ([]*model.Post, error) { for _, field := range fields { if field == "user" { - var wg sync.WaitGroup - wg.Add(len(posts)) var userLoader = dataloadgen.NewLoader(batchUsers, dataloadgen.WithWait(time.Millisecond)) for _, post := range posts { - go func(post *model.Post) { - defer wg.Done() + func(post *model.Post) { user, err := userLoader.Load(ctx, fmt.Sprintf("%d", post.UserID)) if err != nil { return @@ -97,7 +94,6 @@ func (r *queryResolver) Posts(ctx context.Context) ([]*model.Post, error) { post.User = user }(post) } - wg.Wait() break } }