Method parseModel

runtime/parser/parse_model.go:83–283

parseModel parses a model definition and adds the resulting resource to p.Resources.

(ctx context.Context, node *Node)

// parseModel parses a model definition and adds the resulting resource to p.Resources.
func (p *Parser) parseModel(ctx context.Context, node *Node) error {
	// Parse YAML
	tmp := &ModelYAML{}
	err := p.decodeNodeYAML(node, false, tmp)
	if err != nil {
		return err
	}

	// Parse the change mode
	changeMode, err := parseChangeModeYAML(tmp.ChangeMode)
	if err != nil {
		return err
	}

	// Parse refresh schedule
	schedule, err := p.parseScheduleYAML(tmp.Refresh, true)
	if err != nil {
		return err
	}

	// Parse timeout
	var timeout time.Duration
	if tmp.Timeout != "" {
		timeout, err = parseDuration(tmp.Timeout)
		if err != nil {
			return err
		}
	}

	// Build input details
	inputConnector := node.Connector
	inputProps := tmp.InputProperties
	if inputProps == nil {
		inputProps = map[string]any{}
	}
	node.Refs = append(node.Refs, ResourceName{Kind: ResourceKindConnector, Name: inputConnector})

	// Special handling for adding SQL to the input properties
	if sql := strings.TrimSpace(node.SQL); sql != "" {
		refs, err := p.inferSQLRefs(node)
		if err != nil {
			return err
		}
		node.Refs = append(node.Refs, refs...)

		inputProps["sql"] = sql
	}

	// special handling to mark model as updated when local file changes
	if inputConnector == "local_file" {
		err = p.trackResourceNamesForDataPaths(ctx, ResourceName{Kind: ResourceKindModel, Name: node.Name}.Normalized(), inputProps)
		if err != nil {
			return err
		}
	}

	inputPropsPB, err := structpb.NewStruct(inputProps)
	if err != nil {