Function newModel

runtime/controller_test.go:1257–1286

(query, name, source string, rows int64)

}

func newModel(query, name, source string, rows int64) (*runtimev1.Model, *runtimev1.Resource) {
	model := &runtimev1.Model{
		Spec: &runtimev1.ModelSpec{
			RefreshSchedule: &runtimev1.Schedule{RefUpdate: true},
			InputConnector:  "duckdb",
			InputProperties: testruntime.Must(structpb.NewStruct(map[string]any{"sql": query})),
			OutputConnector: "duckdb",
			ChangeMode:      runtimev1.ModelChangeMode_MODEL_CHANGE_MODE_RESET,
		},
		State: &runtimev1.ModelState{
			ExecutorConnector: "duckdb",
			ResultConnector:   "duckdb",
			ResultProperties:  testruntime.Must(structpb.NewStruct(map[string]any{"table": name, "used_model_name": true, "view": true})),
			ResultTable:       name,
			RowsTotal:         rows,
		},
	}
	modelRes := &runtimev1.Resource{
		Meta: &runtimev1.ResourceMeta{
			Name:      &runtimev1.ResourceName{Kind: runtime.ResourceKindModel, Name: name},
			Refs:      []*runtimev1.ResourceName{{Kind: runtime.ResourceKindModel, Name: source}},
			Owner:     runtime.GlobalProjectParserName,
			FilePaths: []string{fmt.Sprintf("/models/%s.sql", name)},
		},
		Resource: &runtimev1.Resource_Model{
			Model: model,
		},
	}
	return model, modelRes
}

func newMetricsView(name, model, parent string, measures, dimensions []any) (*runtimev1.MetricsView, *runtimev1.Resource) {
	var dimensionsSelector, measuresSelector *runtimev1.FieldSelector