fix ruff

bubriks · bubriks · commit c3b7b2857ee5 · 2024-09-30T17:45:11.000+03:00
diff --git a/python/hsfs/core/delta_engine.py b/python/hsfs/core/delta_engine.py
@@ -157,7 +157,7 @@ def _write_delta_dataset(self, dataset, write_options):
         return self._get_last_commit_metadata(
             self._spark_session, location
         )
-    
+
     def vacuum(self, retention_hours):
         location = self._feature_group.prepare_spark_location()
 
diff --git a/python/hsfs/core/feature_group_engine.py b/python/hsfs/core/feature_group_engine.py
@@ -245,7 +245,7 @@ def commit_delete(feature_group, delete_df, write_options):
                 engine.get_instance()._spark_session,
             )
             return hudi_engine_instance.delete_record(delete_df, write_options)
-        
+
     @staticmethod
     def clean(feature_group, write_options):
         if feature_group.time_travel_format == "DELTA":

Original file line number	Diff line number	Diff line change
`@@ -157,7 +157,7 @@ def _write_delta_dataset(self, dataset, write_options):`
`157`	`157`	`return self._get_last_commit_metadata(`
`158`	`158`	`self._spark_session, location`
`159`	`159`	`)`
`160`		`-`
	`160`	`+`
`161`	`161`	`def vacuum(self, retention_hours):`
`162`	`162`	`location = self._feature_group.prepare_spark_location()`
`163`	`163`
Original file line number	Diff line number	Diff line change
`@@ -245,7 +245,7 @@ def commit_delete(feature_group, delete_df, write_options):`
`245`	`245`	`engine.get_instance()._spark_session,`
`246`	`246`	`)`
`247`	`247`	`return hudi_engine_instance.delete_record(delete_df, write_options)`
`248`		`-`
	`248`	`+`
`249`	`249`	`@staticmethod`
`250`	`250`	`def clean(feature_group, write_options):`
`251`	`251`	`if feature_group.time_travel_format == "DELTA":`