refactor: Remove redundant unserialization of artifacts in spark_mate…

…rialization_engine
ExpediaGroup · Feb 3, 2025 · ef6f291 · ef6f291
1 parent 4470a5f
commit ef6f291
Showing 1 changed file with 0 additions and 7 deletions.
diff --git a/sdk/python/feast/infra/materialization/contrib/spark/spark_materialization_engine.py b/sdk/python/feast/infra/materialization/contrib/spark/spark_materialization_engine.py
@@ -235,13 +235,6 @@ def _map_by_partition(
 ):
     feature_view, online_store, repo_config = spark_serialized_artifacts.unserialize()
     """Load pandas df to online store"""
-
-    # unserialize artifacts
-    (
-        feature_view,
-        online_store,
-        repo_config,
-    ) = spark_serialized_artifacts.unserialize()
     for pdf in iterator:
         pdf_row_count = pdf.shape[0]
         start_time = time.time()