fix: Lint

ExpediaGroup · Jan 24, 2025 · 59f376e · 59f376e
1 parent 0e0e8cf
commit 59f376e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdk/python/feast/infra/contrib/spark_kafka_processor.py b/sdk/python/feast/infra/contrib/spark_kafka_processor.py
@@ -395,4 +395,4 @@ def batch_write(row: DataFrame, batch_id: int):
         )
 
         query.awaitTermination(timeout=self.query_timeout)
-        return query
+        return query