Update processed timestamp (#122)

Signed-off-by: Terence Lim <terencelimxp@gmail.com>
feast-dev · Mar 2, 2022 · 1016b97 · 1016b97
1 parent 4fcf740
commit 1016b97
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/feast_spark/pyspark/launcher.py b/python/feast_spark/pyspark/launcher.py
@@ -510,7 +510,7 @@ def get_health_metrics(
             continue
 
         # Ensure ingestion times are in epoch timings
-        last_ingestion_time = json.loads(metric)["last_consumed_kafka_timestamp"][
+        last_ingestion_time = json.loads(metric)["last_processed_event_timestamp"][
             "value"
         ]
         valid_ingestion_time = datetime.timestamp(