Class DbtManifestParser

sdk/python/feast/dbt/parser.py:48–260

Parser for dbt manifest.json files using dbt-artifacts-parser. Uses dbt-artifacts-parser for typed parsing of manifest versions v1-v12 (dbt versions 0.19 through 1.11+). Example:: parser = DbtManifestParser("target/manifest.json") parser.parse() models = p

class DbtManifestParser:
    """
    Parser for dbt manifest.json files using dbt-artifacts-parser.

    Uses dbt-artifacts-parser for typed parsing of manifest versions v1-v12
    (dbt versions 0.19 through 1.11+).

    Example::

        parser = DbtManifestParser("target/manifest.json")
        parser.parse()
        models = parser.get_models(tag_filter="feast")
        for model in models:
            print(f"Model: {model.name}, Columns: {len(model.columns)}")

    Args:
        manifest_path: Path to manifest.json file (typically target/manifest.json)

    Raises:
        FileNotFoundError: If manifest.json doesn't exist
        ValueError: If manifest.json is invalid JSON
    """

    def __init__(self, manifest_path: str):
        """
        Initialize parser.

        Args:
            manifest_path: Path to manifest.json file
        """
        self.manifest_path = Path(manifest_path)
        self._raw_manifest: Optional[Dict[str, Any]] = None
        self._parsed_manifest: Optional[Any] = None

    def parse(self) -> None:
        """
        Load and parse the manifest.json file using dbt-artifacts-parser.

        Raises:
            FileNotFoundError: If manifest.json doesn't exist
            ValueError: If manifest.json is invalid JSON
            ImportError: If dbt-artifacts-parser is not installed
        """
        if not self.manifest_path.exists():
            raise FileNotFoundError(
                f"dbt manifest not found at {self.manifest_path}.\n"
                f"Run 'dbt compile' or 'dbt run' first.\n"
                f"Expected path: <dbt_project>/target/manifest.json"
            )

        try:
            with open(self.manifest_path, "r") as f:
                self._raw_manifest = json.load(f)
        except json.JSONDecodeError as e:
            raise ValueError(
                f"Invalid JSON in manifest: {e}\nTry: dbt clean && dbt compile"
            )