Update processed timestamp (#122)

terryyylim · web-flow · commit 1016b97ce750 · 2022-03-02T00:23:04.000-08:00
Signed-off-by: Terence Lim &lt;terencelimxp@gmail.com&gt;
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(

Original file line number	Diff line number	Diff line change
`@@ -510,7 +510,7 @@ def get_health_metrics(`
`510`	`510`	`continue`
`511`	`511`
`512`	`512`	`# Ensure ingestion times are in epoch timings`
`513`		`- last_ingestion_time = json.loads(metric)["last_consumed_kafka_timestamp"][`
	`513`	`+ last_ingestion_time = json.loads(metric)["last_processed_event_timestamp"][`
`514`	`514`	`"value"`
`515`	`515`	`]`
`516`	`516`	`valid_ingestion_time = datetime.timestamp(`