chunks := chunkBy[db_access.AdGroupPerformanceUpdateParams](p, 1000)
	errGroup, ctx := errgroup.WithContext(ctx)
	errGroup.SetLimit(maxConcurrency)
	for _, chunk := range chunks {
		chunkCopy := chunk
		errGroup.Go(func() error {
			batch := q.AdGroupPerformanceUpdate(ctx, chunkCopy)
			var outsideErr error
			batch.Exec(func(i int, err error) {
				if err != nil {
					outsideErr = err
					batch.Close()
				}
			})
			return outsideErr
		})
	}