Fix

Signed-off-by: Kevin Zhang <kzhang@tecton.ai>

go/cmd/server/server_test.go

@@ -100,7 +100,7 @@ func TestGetFeastServingInfo(t *testing.T) {
 	ctx := context.Background()
 	// Pregenerated using `feast init`.
 	dir := "logging/"
-	err := test.MaterializeInInitializedRepo(dir)
+	err := test.SetupInitializedRepo(dir)
 	assert.Nil(t, err)
 	client, closer := getClient(ctx, "", dir, false)
 	defer closer()
@@ -113,7 +113,7 @@ func TestGetOnlineFeaturesSqlite(t *testing.T) {
 	ctx := context.Background()
 	// Pregenerated using `feast init`.
 	dir := "logging/"
-	err := test.MaterializeInInitializedRepo(dir)
+	err := test.SetupInitializedRepo(dir)
 	assert.Nil(t, err)
 	client, closer := getClient(ctx, "", dir, false)
 	defer closer()
@@ -170,7 +170,7 @@ func TestGetOnlineFeaturesSqliteWithLogging(t *testing.T) {
 	ctx := context.Background()
 	// Pregenerated using `feast init`.
 	dir := "logging/"
-	err := test.MaterializeInInitializedRepo(dir)
+	err := test.SetupInitializedRepo(dir)
 	assert.Nil(t, err)
 	client, closer := getClient(ctx, "file", dir, true)
 	defer closer()

go/internal/test/go_integration_test_utils.go

@@ -1,6 +1,7 @@
 package test
 
 import (
+	"bytes"
 	"context"
 	"fmt"
 
@@ -121,12 +122,22 @@ func SetupCleanFeatureRepo(basePath string) error {
 	return nil
 }
 
-func MaterializeInInitializedRepo(basePath string) error {
+func SetupInitializedRepo(basePath string) error {
 	path, err := filepath.Abs(basePath)
 	if err != nil {
 		return err
 	}
-	feature_repo_path, err := filepath.Abs(filepath.Join(path, "feature_repo/"))
+	applyCommand := exec.Command("feast", "apply")
+	applyCommand.Env = os.Environ()
+	feature_repo_path, err := filepath.Abs(filepath.Join(path, "feature_repo"))
+	if err != nil {
+		return err
+	}
+	var stderr bytes.Buffer
+
+	applyCommand.Dir = feature_repo_path
+	applyCommand.Stderr = &stderr
+	err = applyCommand.Run()
 	if err != nil {
 		return err
 	}
@@ -135,6 +146,7 @@ func MaterializeInInitializedRepo(basePath string) error {
 	formattedTime := fmt.Sprintf("%d-%02d-%02dT%02d:%02d:%02d",
 		t.Year(), t.Month(), t.Day(),
 		t.Hour(), t.Minute(), t.Second())
+
 	materializeCommand := exec.Command("feast", "materialize-incremental", formattedTime)
 	materializeCommand.Env = os.Environ()
 	materializeCommand.Dir = feature_repo_path