pre-commit changes

Signed-off-by: zerafachris PERSONAL <[email protected]>
feast-dev · Jan 6, 2025 · 57e773f · 57e773f
1 parent e75d483
commit 57e773f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/sdk/python/feast/data_source.py b/sdk/python/feast/data_source.py
@@ -92,7 +92,7 @@ def to_proto(self) -> DataSourceProto.KafkaOptions:
         if self.watermark_delay_threshold is not None:
             watermark_delay_threshold = Duration()
             watermark_delay_threshold.FromTimedelta(self.watermark_delay_threshold)
-            
+
         kafka_settings = None
         if self.kafka_settings is not None:
             kafka_settings = self.kafka_settings

diff --git a/sdk/python/feast/infra/contrib/spark_kafka_processor.py b/sdk/python/feast/infra/contrib/spark_kafka_processor.py
@@ -91,8 +91,8 @@ def _ingest_stream_data(self) -> StreamTable:
         )
 
         if self.data_source.kafka_options.kafka_settings is not None:
-            for k,v in self.data_source.kafka_options.kafka_settings.items():
-                stream_df = stream_df.option(k,v)
+            for k, v in self.data_source.kafka_options.kafka_settings.items():
+                stream_df = stream_df.option(k, v)
 
         stream_df = stream_df.load().selectExpr("CAST(value AS STRING)")