We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ea8ad17 commit d9008f1Copy full SHA for d9008f1
sdk/python/feast/infra/materialization/contrib/bytewax/dataflow.py
@@ -12,10 +12,10 @@
12
logging.basicConfig(level=logging.INFO)
13
14
with open("/var/feast/feature_store.yaml") as f:
15
- feast_config = yaml.safe_load(f)
+ feast_config = yaml.load(f, Loader=yaml.Loader)
16
17
with open("/var/feast/bytewax_materialization_config.yaml") as b:
18
- bytewax_config = yaml.safe_load(b)
+ bytewax_config = yaml.load(b, Loader=yaml.Loader)
19
20
config = RepoConfig(**feast_config)
21
store = FeatureStore(config=config)
0 commit comments