Class Registry

sdk/python/feast/infra/registry/registry.py:167–1671

class Registry(BaseRegistry):
    def apply_user_metadata(
        self,
        project: str,
        feature_view: BaseFeatureView,
        metadata_bytes: Optional[bytes],
    ):
        pass

    def get_user_metadata(
        self, project: str, feature_view: BaseFeatureView
    ) -> Optional[bytes]:
        pass

    def set_project_metadata(self, project: str, key: str, value: str):
        """Set a custom project metadata key-value pair in the registry backend."""
        if hasattr(self._registry_store, "set_project_metadata"):
            self._registry_store.set_project_metadata(project, key, value)
        else:
            raise NotImplementedError(
                "set_project_metadata not implemented for this registry backend"
            )

    def get_project_metadata(self, project: str, key: str) -> Optional[str]:
        """Get a custom project metadata value by key from the registry backend."""
        if hasattr(self._registry_store, "get_project_metadata"):
            return self._registry_store.get_project_metadata(project, key)
        else:
            raise NotImplementedError(
                "get_project_metadata not implemented for this registry backend"
            )

    # The cached_registry_proto object is used for both reads and writes. In particular,
    # all write operations refresh the cache and modify it in memory; the write must
    # then be persisted to the underlying RegistryStore with a call to commit().
    cached_registry_proto: RegistryProto
    cached_registry_proto_created: datetime
    cached_registry_proto_ttl: timedelta

    def __init__(
        self,
        project: str,
        registry_config: Optional[RegistryConfig],
        repo_path: Optional[Path],
        auth_config: AuthConfig = NoAuthConfig(),
    ):
        """
        Create the Registry object.

        Args:
            registry_config: RegistryConfig object containing the destination path and cache ttl,
            repo_path: Path to the base of the Feast repository
            or where it will be created if it does not exist yet.
        """

        self._refresh_lock = Lock()
        self._auth_config = auth_config