fix: Bytewax engine create configmap from object (feast-dev#3821)

sudohainguyen · Bhargav Dodla · commit c8f78874690c · 2024-06-10T16:03:47.000-07:00
fix: bytewax engine create configmap from object

Signed-off-by: Hai Nguyen &lt;quanghai.ng1512@gmail.com&gt;
diff --git a/sdk/python/feast/infra/materialization/contrib/bytewax/bytewax_materialization_engine.py b/sdk/python/feast/infra/materialization/contrib/bytewax/bytewax_materialization_engine.py
@@ -23,7 +23,7 @@
 from feast.infra.registry.base_registry import BaseRegistry
 from feast.repo_config import FeastConfigBaseModel
 from feast.stream_feature_view import StreamFeatureView
-from feast.utils import _get_column_names, get_default_yaml_file_path
+from feast.utils import _get_column_names
 
 from .bytewax_materialization_job import BytewaxMaterializationJob
 
@@ -187,10 +187,7 @@ def _create_kubernetes_job(self, job_id, paths, feature_view):
     def _create_configuration_map(self, job_id, paths, feature_view, namespace):
         """Create a Kubernetes configmap for this job"""
 
-        repo_path = self.repo_config.repo_path
-        assert repo_path
-        feature_store_path = get_default_yaml_file_path(repo_path)
-        feature_store_configuration = feature_store_path.read_text()
+        feature_store_configuration = yaml.dump(self.repo_config.dict())
 
         materialization_config = yaml.dump(
             {"paths": paths, "feature_view": feature_view.name}
