style: ruff format spark.py and spark_source.py

abhijeet-dhumal · abhijeet-dhumal · commit c9d77ff839b0 · 2026-05-27T17:13:01.000+05:30
Signed-off-by: abhijeet-dhumal &lt;abhijeetdhumal652@gmail.com&gt;
diff --git a/sdk/python/feast/infra/offline_stores/contrib/spark_offline_store/spark.py b/sdk/python/feast/infra/offline_stores/contrib/spark_offline_store/spark.py
@@ -130,8 +130,7 @@ def _apply_bfv_transformations_for_historical(
             hasattr(fv, "feature_transformation")
             and fv.feature_transformation is not None
             and (
-                getattr(fv.feature_transformation, "mode", None)
-                in ("python", "pandas")
+                getattr(fv.feature_transformation, "mode", None) in ("python", "pandas")
                 or getattr(
                     getattr(fv.feature_transformation, "mode", None), "value", None
                 )
@@ -144,9 +143,7 @@ def _apply_bfv_transformations_for_historical(
             if udf is not None:
                 temp_view_name = f"__feast_bfv_{ctx.name}_{uuid.uuid4().hex[:8]}"
                 spark_session.conf.set("spark.sql.runSQLOnFiles", "true")
-                raw_df = spark_session.sql(
-                    f"SELECT * FROM {ctx.table_subquery}"
-                )
+                raw_df = spark_session.sql(f"SELECT * FROM {ctx.table_subquery}")
                 transformed_df = udf(raw_df)
                 transformed_df.createOrReplaceTempView(temp_view_name)
                 ctx = replace(ctx, table_subquery=temp_view_name)
diff --git a/sdk/python/feast/infra/offline_stores/contrib/spark_offline_store/spark_source.py b/sdk/python/feast/infra/offline_stores/contrib/spark_offline_store/spark_source.py
@@ -294,9 +294,7 @@ def __init__(
         has_query = bool(query)
         has_path = bool(path)
         if has_table and (has_query or has_path):
-            raise ValueError(
-                "'table' cannot be combined with 'query' or 'path'."
-            )
+            raise ValueError("'table' cannot be combined with 'query' or 'path'.")
         if not (has_table or has_query or has_path):
             raise ValueError(
                 "At least one of params(table, query, path) must be specified."
