fix: build Spark DataFrame from Arrow with schema and empty handling(#5594)

jfw-ppi · jfw-ppi · commit b77a7404a5ad · 2026-01-01T23:18:08.000+01:00
Signed-off-by: Jacob Weinhold &lt;29459386+jfw-ppi@users.noreply.github.com&gt;
diff --git a/sdk/python/feast/infra/compute_engines/spark/nodes.py b/sdk/python/feast/infra/compute_engines/spark/nodes.py
@@ -90,7 +90,6 @@ def execute(self, context: ExecutionContext) -> DAGValue:
             else:
                 spark_df = self.spark_session.createDataFrame(arrow_table.to_pandas())
 
-
         return DAGValue(
             data=spark_df,
             format=DAGFormat.SPARK,
@@ -103,6 +102,7 @@ def execute(self, context: ExecutionContext) -> DAGValue:
             },
         )
 
+
 class SparkAggregationNode(DAGNode):
     def __init__(
         self,
