feat: batch_engine config injection in feature_store.yaml through ope…

…rator Signed-off-by: Aniket Paluskar <apaluska@redhat.com>
ntkathole · Feb 10, 2026 · Feb 3, 2026 · Feb 5, 2026 · Feb 9, 2026 · Feb 10, 2026
commit 7159e6f6a4deb868943a092cc249a4aa4177390b
@@ -652,7 +652,7 @@ func getQualifiedFeatureName(viewName string, featureName string, fullFeatureNam
 func validateJoinKeys(
 	joinKeyValues map[string]*prototypes.RepeatedValue,
 	expectedJoinKeysSet map[string]interface{}) error {
-	for joinKey, _ := range joinKeyValues {
+	for joinKey := range joinKeyValues {
 		if _, ok := expectedJoinKeysSet[joinKey]; !ok {
 			return fmt.Errorf("Invalid entity join key. key=%s", joinKey)
 		}

@@ -9,7 +9,6 @@ import (
 	prototypes "github.com/feast-dev/feast/go/protos/feast/types"
 	"github.com/feast-dev/feast/go/types"
 	"github.com/google/uuid"
-
 )
 
 const feastServerVersion = "0.0.1"

@@ -4,8 +4,8 @@ import (
 	"os"
 
 	"github.com/rs/zerolog"
-	"go.opentelemetry.io/otel/trace"
 	"go.opentelemetry.io/otel"
+	"go.opentelemetry.io/otel/trace"
 )
 
 var tracer = otel.Tracer("github.com/feast-dev/feast/go/server")

@@ -75,6 +75,7 @@ type FeatureStoreSpec struct {
 	Services        *FeatureStoreServices `json:"services,omitempty"`
 	AuthzConfig     *AuthzConfig          `json:"authz,omitempty"`
 	CronJob         *FeastCronJob         `json:"cronJob,omitempty"`
+	BatchEngine     *BatchEngineConfig    `json:"batchEngine,omitempty"`
 }
 
 // FeastProjectDir defines how to create the feast project directory.
@@ -155,6 +156,15 @@ type FeastCronJob struct {
 	FailedJobsHistoryLimit *int32 `json:"failedJobsHistoryLimit,omitempty"`
 }
 
+// BatchEngineConfig defines the batch compute engine configuration.
+type BatchEngineConfig struct {
+	// Reference to a ConfigMap containing the batch engine configuration.
+	// The ConfigMap should contain YAML-formatted config with 'type' and engine-specific fields.
+	ConfigMapRef *corev1.LocalObjectReference `json:"configMapRef,omitempty"`
+	// Key name in the ConfigMap. Defaults to "config" if not specified.
+	ConfigMapKey string `json:"configMapKey,omitempty"`
+}
+
 // JobSpec describes how the job execution will look like.
 type JobSpec struct {
 	// PodTemplateAnnotations are annotations to be applied to the CronJob's PodTemplate

@@ -50,7 +50,7 @@ metadata:
         }
       ]
     capabilities: Basic Install
-    createdAt: "2026-01-31T05:08:59Z"
+    createdAt: "2026-02-03T08:12:50Z"
     operators.operatorframework.io/builder: operator-sdk-v1.38.0
     operators.operatorframework.io/project_layout: go.kubebuilder.io/v4
   name: feast-operator.v0.59.0

@@ -83,6 +83,27 @@ spec:
                 x-kubernetes-validations:
                 - message: One selection required between kubernetes or oidc.
                   rule: '[has(self.kubernetes), has(self.oidc)].exists_one(c, c)'
+              batchEngine:
+                description: BatchEngineConfig defines the batch compute engine configuration.
+                properties:
+                  configMapKey:
+                    description: Key name in the ConfigMap. Defaults to "config" if
+                      not specified.
+                    type: string
+                  configMapRef:
+                    description: Reference to a ConfigMap containing the batch engine
+                      configuration.
+                    properties:
+                      name:
+                        default: ""
+                        description: |-
+                          Name of the referent.
+                          This field is effectively required, but due to backwards compatibility is
+                          allowed to be empty.
+                        type: string
+                    type: object
+                    x-kubernetes-map-type: atomic
+                type: object
               cronJob:
                 description: FeastCronJob defines a CronJob to execute against a Feature
                   Store deployment.
@@ -4287,6 +4308,28 @@ spec:
                     - message: One selection required between kubernetes or oidc.
                       rule: '[has(self.kubernetes), has(self.oidc)].exists_one(c,
                         c)'
+                  batchEngine:
+                    description: BatchEngineConfig defines the batch compute engine
+                      configuration.
+                    properties:
+                      configMapKey:
+                        description: Key name in the ConfigMap. Defaults to "config"
+                          if not specified.
+                        type: string
+                      configMapRef:
+                        description: Reference to a ConfigMap containing the batch
+                          engine configuration.
+                        properties:
+                          name:
+                            default: ""
+                            description: |-
+                              Name of the referent.
+                              This field is effectively required, but due to backwards compatibility is
+                              allowed to be empty.
+                            type: string
+                        type: object
+                        x-kubernetes-map-type: atomic
+                    type: object
                   cronJob:
                     description: FeastCronJob defines a CronJob to execute against
                       a Feature Store deployment.

@@ -83,6 +83,27 @@ spec:
                 x-kubernetes-validations:
                 - message: One selection required between kubernetes or oidc.
                   rule: '[has(self.kubernetes), has(self.oidc)].exists_one(c, c)'
+              batchEngine:
+                description: BatchEngineConfig defines the batch compute engine configuration.
+                properties:
+                  configMapKey:
+                    description: Key name in the ConfigMap. Defaults to "config" if
+                      not specified.
+                    type: string
+                  configMapRef:
+                    description: Reference to a ConfigMap containing the batch engine
+                      configuration.
+                    properties:
+                      name:
+                        default: ""
+                        description: |-
+                          Name of the referent.
+                          This field is effectively required, but due to backwards compatibility is
+                          allowed to be empty.
+                        type: string
+                    type: object
+                    x-kubernetes-map-type: atomic
+                type: object
               cronJob:
                 description: FeastCronJob defines a CronJob to execute against a Feature
                   Store deployment.
@@ -4287,6 +4308,28 @@ spec:
                     - message: One selection required between kubernetes or oidc.
                       rule: '[has(self.kubernetes), has(self.oidc)].exists_one(c,
                         c)'
+                  batchEngine:
+                    description: BatchEngineConfig defines the batch compute engine
+                      configuration.
+                    properties:
+                      configMapKey:
+                        description: Key name in the ConfigMap. Defaults to "config"
+                          if not specified.
+                        type: string
+                      configMapRef:
+                        description: Reference to a ConfigMap containing the batch
+                          engine configuration.
+                        properties:
+                          name:
+                            default: ""
+                            description: |-
+                              Name of the referent.
+                              This field is effectively required, but due to backwards compatibility is
+                              allowed to be empty.
+                            type: string
+                        type: object
+                        x-kubernetes-map-type: atomic
+                    type: object
                   cronJob:
                     description: FeastCronJob defines a CronJob to execute against
                       a Feature Store deployment.

diff --git a/infra/feast-operator/config/manager/kustomization.yaml b/infra/feast-operator/config/manager/kustomization.yaml
@@ -4,5 +4,5 @@ apiVersion: kustomize.config.k8s.io/v1beta1
 kind: Kustomization
 images:
 - name: controller
-  newName: quay.io/feastdev/feast-operator
-  newTag: 0.59.0
+  newName: quay.io/aniket-redhat/feast-operator
+  newTag: dev0.8
@@ -91,6 +91,27 @@ spec:
                 x-kubernetes-validations:
                 - message: One selection required between kubernetes or oidc.
                   rule: '[has(self.kubernetes), has(self.oidc)].exists_one(c, c)'
+              batchEngine:
+                description: BatchEngineConfig defines the batch compute engine configuration.
+                properties:
+                  configMapKey:
+                    description: Key name in the ConfigMap. Defaults to "config" if
+                      not specified.
+                    type: string
+                  configMapRef:
+                    description: Reference to a ConfigMap containing the batch engine
+                      configuration.
+                    properties:
+                      name:
+                        default: ""
+                        description: |-
+                          Name of the referent.
+                          This field is effectively required, but due to backwards compatibility is
+                          allowed to be empty.
+                        type: string
+                    type: object
+                    x-kubernetes-map-type: atomic
+                type: object
               cronJob:
                 description: FeastCronJob defines a CronJob to execute against a Feature
                   Store deployment.
@@ -4295,6 +4316,28 @@ spec:
                     - message: One selection required between kubernetes or oidc.
                       rule: '[has(self.kubernetes), has(self.oidc)].exists_one(c,
                         c)'
+                  batchEngine:
+                    description: BatchEngineConfig defines the batch compute engine
+                      configuration.
+                    properties:
+                      configMapKey:
+                        description: Key name in the ConfigMap. Defaults to "config"
+                          if not specified.
+                        type: string
+                      configMapRef:
+                        description: Reference to a ConfigMap containing the batch
+                          engine configuration.
+                        properties:
+                          name:
+                            default: ""
+                            description: |-
+                              Name of the referent.
+                              This field is effectively required, but due to backwards compatibility is
+                              allowed to be empty.
+                            type: string
+                        type: object
+                        x-kubernetes-map-type: atomic
+                    type: object
                   cronJob:
                     description: FeastCronJob defines a CronJob to execute against
                       a Feature Store deployment.

@@ -28,6 +28,22 @@ _Appears in:_
 | `oidc` _[OidcAuthz](#oidcauthz)_ |  |
 
 
+#### BatchEngineConfig
+
+
+
+BatchEngineConfig defines the batch compute engine configuration.
+
+_Appears in:_
+- [FeatureStoreSpec](#featurestorespec)
+
+| Field | Description |
+| --- | --- |
+| `configMapRef` _[LocalObjectReference](https://kubernetes.io/docs/reference/generated/kubernetes-api/v1.30/#localobjectreference-v1-core)_ | Reference to a ConfigMap containing the batch engine configuration.
+The ConfigMap should contain YAML-formatted config with 'type' and engine-specific fields. |
+| `configMapKey` _string_ | Key name in the ConfigMap. Defaults to "config" if not specified. |
+
+
 #### ContainerConfigs
 
 
@@ -226,6 +242,7 @@ _Appears in:_
 | `services` _[FeatureStoreServices](#featurestoreservices)_ |  |
 | `authz` _[AuthzConfig](#authzconfig)_ |  |
 | `cronJob` _[FeastCronJob](#feastcronjob)_ |  |
+| `batchEngine` _[BatchEngineConfig](#batchengineconfig)_ |  |
 
 
 #### FeatureStoreStatus