Method tryRunCheckScaleOut

core/modtree.go:258–311

(ctx context.Context)

}

func (node *ModTreeNode) tryRunCheckScaleOut(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("check").Arg("name", node.moduleLocalPathString())
	query = query.Select("run")
	query = query.Select("error")
	query = query.Select("id")

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

	if errID != "" {
		srv, err := CurrentDagqlServer(ctx)
		if err != nil {
			return true, err
		}
		var idp call.ID
		if err := idp.Decode(errID); err != nil {
			return true, err
		}
		errObj, err := dagql.NewID[*Error](&idp).Load(ctx, srv)
		if err != nil {
			return true, err
		}
		return true, errObj.Self()
	}

	return true, nil
}

// ServiceNameAttr is the telemetry attribute key for the service name.
// Defined locally because the canonical constant lives in the external