Skip to content

Commit 25e9775

Browse files
fix: Bytewax engine create configmap from object (#3821)
fix: bytewax engine create configmap from object Signed-off-by: Hai Nguyen <quanghai.ng1512@gmail.com>
1 parent 9583ed6 commit 25e9775

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

sdk/python/feast/infra/materialization/contrib/bytewax/bytewax_materialization_engine.py

+2-5
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727
from feast.infra.registry.base_registry import BaseRegistry
2828
from feast.repo_config import FeastConfigBaseModel
2929
from feast.stream_feature_view import StreamFeatureView
30-
from feast.utils import _get_column_names, get_default_yaml_file_path
30+
from feast.utils import _get_column_names
3131

3232
from .bytewax_materialization_job import BytewaxMaterializationJob
3333

@@ -307,10 +307,7 @@ def _create_kubernetes_job(self, job_id, paths, feature_view):
307307
def _create_configuration_map(self, job_id, paths, feature_view, namespace):
308308
"""Create a Kubernetes configmap for this job"""
309309

310-
repo_path = self.repo_config.repo_path
311-
assert repo_path
312-
feature_store_path = get_default_yaml_file_path(repo_path)
313-
feature_store_configuration = feature_store_path.read_text()
310+
feature_store_configuration = yaml.dump(self.repo_config.dict())
314311

315312
materialization_config = yaml.dump(
316313
{"paths": paths, "feature_view": feature_view.name}

0 commit comments

Comments
 (0)