From 6a96b0693f6aae9d892d60c1b3a88fecfc0dfd89 Mon Sep 17 00:00:00 2001 From: bubriks Date: Fri, 20 Dec 2024 17:16:10 +0200 Subject: [PATCH] fix --- python/hsfs/engine/spark.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/python/hsfs/engine/spark.py b/python/hsfs/engine/spark.py index f20cc88b5..b3f64e87d 100644 --- a/python/hsfs/engine/spark.py +++ b/python/hsfs/engine/spark.py @@ -523,7 +523,7 @@ def save_stream_dataframe( "wait_for_online_ingestion", False ): feature_group.get_latest_online_ingestion().wait_for_completion( - options=offline_write_options.get("online_ingestion_options", {}) + options=write_options.get("online_ingestion_options", {}) ) return query @@ -586,7 +586,7 @@ def _save_online_dataframe(self, feature_group, dataframe, write_options): "wait_for_online_ingestion", False ): feature_group.get_latest_online_ingestion().wait_for_completion( - options=offline_write_options.get("online_ingestion_options", {}) + options=write_options.get("online_ingestion_options", {}) ) def _get_headers(