Method create_all_from_model

sdk/python/feast/dbt/mapper.py:413–480

Create all Feast objects (DataSource, Entity, FeatureView) from a dbt model. This is a convenience method that creates all necessary Feast objects in one call. Args: model: The DbtModel to create objects from entity_columns: Entity column na

(
        self,
        model: DbtModel,
        entity_columns: Union[str, List[str]],
        timestamp_field: Optional[str] = None,
        ttl_days: Optional[int] = None,
        exclude_columns: Optional[List[str]] = None,
        online: bool = True,
    )

        )

    def create_all_from_model(
        self,
        model: DbtModel,
        entity_columns: Union[str, List[str]],
        timestamp_field: Optional[str] = None,
        ttl_days: Optional[int] = None,
        exclude_columns: Optional[List[str]] = None,
        online: bool = True,
    ) -> Dict[str, Union[List[Entity], Any, FeatureView]]:
        """
        Create all Feast objects (DataSource, Entity, FeatureView) from a dbt model.

        This is a convenience method that creates all necessary Feast objects
        in one call.

        Args:
            model: The DbtModel to create objects from
            entity_columns: Entity column name(s) - single string or list of strings
            timestamp_field: Override the default timestamp field
            ttl_days: Override the default TTL in days
            exclude_columns: Additional columns to exclude from features
            online: Whether to enable online serving

        Returns:
            Dict with keys 'entities', 'data_source', 'feature_view'
        """
        # Normalize to list
        entity_cols: List[str] = (
            [entity_columns]
            if isinstance(entity_columns, str)
            else list(entity_columns)
        )

        # Create entities (plural)
        entities_list = []
        for entity_col in entity_cols:
            entity_value_type = self._infer_entity_value_type(model, entity_col)
            entity = self.create_entity(
                name=entity_col,
                description=f"Entity for {model.name}",
                tags={"dbt.model": model.name},
                value_type=entity_value_type,
            )
            entities_list.append(entity)

        # Create data source
        data_source = self.create_data_source(
            model=model,
            timestamp_field=timestamp_field,
        )

        # Create feature view
        feature_view = self.create_feature_view(
            model=model,
            source=data_source,
            entity_columns=entity_cols,
            entities=entities_list,
            timestamp_field=timestamp_field,