ruff fix

bubriks · bubriks · commit afe70f4bfb27 · 2024-10-15T11:34:59.000+03:00
diff --git a/python/hsfs/engine/spark.py b/python/hsfs/engine/spark.py
@@ -630,7 +630,7 @@ def _serialize_to_avro(
                 ).alias("value"),
             ]
         )
-    
+
     def _deserialize_from_avro(
             self,
             feature_group: Union[fg_mod.FeatureGroup, fg_mod.ExternalFeatureGroup],
@@ -642,7 +642,7 @@ def _deserialize_from_avro(
             decoded_dataframe = dataframe.select(
                 from_avro("value", feature_group._get_encoded_avro_schema()).alias("value")
             ).select(col("value.*"))
-            
+
             """Decodes all complex type features from binary using their avro type as schema."""
             return decoded_dataframe.select(
                 [

Original file line number	Diff line number	Diff line change
`@@ -630,7 +630,7 @@ def _serialize_to_avro(`
`630`	`630`	`).alias("value"),`
`631`	`631`	`]`
`632`	`632`	`)`
`633`		`-`
	`633`	`+`
`634`	`634`	`def _deserialize_from_avro(`
`635`	`635`	`self,`
`636`	`636`	`feature_group: Union[fg_mod.FeatureGroup, fg_mod.ExternalFeatureGroup],`
`@@ -642,7 +642,7 @@ def _deserialize_from_avro(`
`642`	`642`	`decoded_dataframe = dataframe.select(`
`643`	`643`	`from_avro("value", feature_group._get_encoded_avro_schema()).alias("value")`
`644`	`644`	`).select(col("value.*"))`
`645`		`-`
	`645`	`+`
`646`	`646`	`"""Decodes all complex type features from binary using their avro type as schema."""`
`647`	`647`	`return decoded_dataframe.select(`
`648`	`648`	`[`