@@ -99,7 +99,7 @@ def cli(
    ctx.obj["FS_YAML_FILE"] = (
        Path(feature_store_yaml).absolute()
        if feature_store_yaml
-        else ctx.obj["CHDIR"] / "feature_store.yaml"
    )
    try:
        level = getattr(logging, log_level.upper())

@@ -23,6 +23,9 @@
# feature_store.yaml environment variable name for remote feature server
FEATURE_STORE_YAML_ENV_NAME: str = "FEATURE_STORE_YAML_BASE64"

# Environment variable for registry
REGISTRY_ENV_NAME: str = "REGISTRY_BASE64"


@@ -160,7 +160,7 @@ def __init__(
            self.config = load_repo_config(self.repo_path, fs_yaml_file)
        else:
            self.config = load_repo_config(
-                self.repo_path, Path(self.repo_path) / "feature_store.yaml"
            )

        registry_config = self.config.get_registry_config()

@@ -8,6 +8,7 @@

from colorama import Fore, Style

from feast.constants import (
    AWS_LAMBDA_FEATURE_SERVER_IMAGE,
    AWS_LAMBDA_FEATURE_SERVER_REPOSITORY,
@@ -113,7 +114,10 @@ def _deploy_feature_server(self, project: str, image_uri: str):

        if not self.repo_config.repo_path:
            raise RepoConfigPathDoesNotExist()
-        with open(self.repo_config.repo_path / "feature_store.yaml", "rb") as f:
            config_bytes = f.read()
            config_base64 = base64.b64encode(config_bytes).decode()


@@ -1,6 +1,8 @@
import typing
from collections import defaultdict
from datetime import datetime
from typing import Dict, List, Optional, Tuple, Union

import pandas as pd
@@ -9,6 +11,7 @@
from dateutil.tz import tzlocal
from pytz import utc

from feast.entity import Entity
from feast.protos.feast.types.EntityKey_pb2 import EntityKey as EntityKeyProto
from feast.protos.feast.types.Value_pb2 import Value as ValueProto
@@ -51,6 +54,14 @@ def maybe_local_tz(t: datetime) -> datetime:
        return t


def _get_requested_feature_views_to_features_dict(
    feature_refs: List[str],
    feature_views: List["FeatureView"],

@@ -1,7 +1,9 @@
import tempfile
from contextlib import contextmanager
from pathlib import Path
from textwrap import dedent

from assertpy import assertpy

@@ -85,6 +87,21 @@ def test_3rd_party_registry_store_with_fs_yaml_override() -> None:
        assertpy.assert_that(return_code).is_equal_to(0)


@contextmanager
def setup_third_party_provider_repo(provider_name: str):
    with tempfile.TemporaryDirectory() as repo_dir_name: