Method decodeNodeYAML

runtime/parser/parse_node.go:331–375

decodeNodeYAML decodes a Node into a YAML struct. If knownFields is true, it will return an error if the YAML contains unknown fields. It applies defaults from rill.yaml, then the YAML, then the YAML's environment-specific overrides, and finally the SQL annotations. If an error is returned, it will

(node *Node, knownFields bool, dst any)

// It applies defaults from rill.yaml, then the YAML, then the YAML's environment-specific overrides, and finally the SQL annotations.
// If an error is returned, it will be a pathError associated with the node.
func (p *Parser) decodeNodeYAML(node *Node, knownFields bool, dst any) error {
	// Apply defaults from rill.yaml
	if p.RillYAML != nil {
		defaults := p.RillYAML.Defaults[node.Kind]
		if !defaults.IsZero() {
			if err := defaults.Decode(dst); err != nil {
				return pathError{path: node.YAMLPath, err: fmt.Errorf("failed applying defaults from rill.yaml: %w", err)}
			}
		}
	}

	// Apply YAML
	if node.YAML != nil {
		var err error
		if knownFields {
			// Using node.YAMLRaw instead of node.YAML because we need to set KnownFields for metrics views
			dec := yaml.NewDecoder(strings.NewReader(node.YAMLRaw))
			dec.KnownFields(true)
			err = dec.Decode(dst)
		} else {
			err = node.YAML.Decode(dst)
		}
		if err != nil {
			return pathError{path: node.YAMLPath, err: newYAMLError(err)}
		}
	}

	// Override YAML config with SQL annotations
	if len(node.SQLAnnotations) > 0 {
		err := mapstructureUnmarshal(node.SQLAnnotations, dst)
		if err != nil {
			return pathError{path: node.SQLPath, err: fmt.Errorf("invalid SQL annotations: %w", err)}
		}
	}

	// Apply environment-specific overrides
	if node.YAMLOverride != nil {
		err := node.YAMLOverride.Decode(dst)
		if err != nil {
			return pathError{path: node.YAMLPath, err: newYAMLError(err)}
		}
	}

	return nil
}

// parseYAMLRefs parses a list of YAML nodes into a list of ResourceNames.
// It's used to parse the "refs" field in baseConfig.