skip updating processor status with null values for timestamp (#511)

* skip updating processor status with null values for timestamp * lint
aptos-labs · Sep 17, 2024 · c42d401 · c42d401
1 parent 29b7a94
commit c42d401
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/rust/processor/src/gap_detectors/mod.rs b/rust/processor/src/gap_detectors/mod.rs
@@ -131,6 +131,12 @@ pub async fn create_gap_detector_status_tracker_loop(
                     Ok(res) => {
                         match res {
                             GapDetectorResult::ParquetFileGapDetectorResult(res) => {
+                                if res.last_transaction_timestamp.is_none() {
+                                    // we don't want to update the last processed version if we haven't processed anything
+                                    tracing::info!("No transactions processed, skipping update the processor status");
+                                    continue;
+                                }
+
                                 PARQUET_PROCESSOR_DATA_GAP_COUNT
                                     .with_label_values(&[processor_name])
                                     .set(res.num_gaps as i64);