fix: reverted the logging change

ExpediaGroup · Feb 11, 2025 · b6ff0f9 · b6ff0f9
1 parent cea7a19
commit b6ff0f9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdk/python/feast/infra/materialization/contrib/spark/spark_materialization_engine.py b/sdk/python/feast/infra/materialization/contrib/spark/spark_materialization_engine.py
@@ -268,7 +268,7 @@ def _map_by_partition(
         )
         end_time = time.time()
         print(
-            f"INFO: Processed batch with size {pdf_row_count} in {int((end_time - start_time) * 1000)} milliseconds"
+            f"INFO!!! Processed batch with size {pdf_row_count} in {int((end_time - start_time) * 1000)} milliseconds"
         )
     yield pd.DataFrame(
         [pd.Series(range(1, 2))]