Method tryRunGeneratorAsCheckScaleOut

core/modtree.go:191–232

(ctx context.Context)

}

func (node *ModTreeNode) tryRunGeneratorAsCheckScaleOut(ctx context.Context) (_ bool, rerr error) {
	q, err := CurrentQuery(ctx)
	if err != nil {
		return true, err
	}

	cloudClient, useCloud, err := q.CloudEngineClient(ctx,
		node.RootAddress(),
		node.PathString(),
		nil,
	)
	if err != nil {
		return true, fmt.Errorf("engine-to-engine connect: %w", err)
	}
	if !useCloud {
		return false, nil
	}
	defer func() {
		rerr = errors.Join(rerr, cloudClient.Close())
	}()

	query, err := node.buildScaleOutModuleQuery(cloudClient.Dagger().QueryBuilder())
	if err != nil {
		return true, err
	}

	query = query.Select("generator").Arg("name", node.moduleLocalPathString())
	query = query.Select("run")
	query = query.Select("isEmpty")

	var empty bool
	if err := query.Bind(&empty).Execute(ctx); err != nil {
		return true, err
	}

	if !empty {
		return true, fmt.Errorf("generate function %s produced changes; run 'dagger generate %s' to apply",
			node.PathString(), node.PathString())
	}

	return true, nil
}

func (node *ModTreeNode) runCheckLocally(ctx context.Context) error {
	var status dagql.AnyResult