bump sdk

aptos-labs · Aug 14, 2024 · e4be032 · e4be032
1 parent a41965e
commit e4be032
Show file tree

Hide file tree

Showing 5 changed files with 28 additions and 30 deletions.
diff --git a/rust/Cargo.lock b/rust/Cargo.lock
diff --git a/rust/Cargo.toml b/rust/Cargo.toml
@@ -26,12 +26,11 @@ sdk-processor = { path = "sdk-processor" }
 
 ahash = { version = "0.8.7", features = ["serde"] }
 anyhow = "1.0.86"
-aptos-indexer-processor-sdk = { git = "https://github.com/aptos-labs/aptos-indexer-processor-sdk.git", rev = "7064ed5c0a2f5571535f1c25db7c5705e3d736fc" }
-aptos-indexer-processor-sdk-server-framework = { git = "https://github.com/aptos-labs/aptos-indexer-processor-sdk.git", rev = "7064ed5c0a2f5571535f1c25db7c5705e3d736fc" }
+aptos-indexer-processor-sdk = { git = "https://github.com/aptos-labs/aptos-indexer-processor-sdk.git", rev = "e1e1bdd9349f0a68c9fc53b7e2cebda9e2ce92b7" }
+aptos-indexer-processor-sdk-server-framework = { git = "https://github.com/aptos-labs/aptos-indexer-processor-sdk.git", rev = "e1e1bdd9349f0a68c9fc53b7e2cebda9e2ce92b7" }
 aptos-protos = { git = "https://github.com/aptos-labs/aptos-core.git", rev = "5c48aee129b5a141be2792ffa3d9bd0a1a61c9cb" }
 aptos-system-utils = { git = "https://github.com/aptos-labs/aptos-core.git", rev = "4541add3fd29826ec57f22658ca286d2d6134b93" }
 async-trait = "0.1.53"
-autometrics = { version = "1.0.1", features = ["prometheus-exporter"] }
 backtrace = "0.3.58"
 base64 = "0.13.0"
 bb8 = "0.8.1"
@@ -81,7 +80,6 @@ once_cell = "1.10.0"
 num_cpus = "1.16.0"
 pbjson = "0.5.1"
 prometheus = { version = "0.13.0", default-features = false }
-prometheus-client = "0.22.3"
 prost = { version = "0.12.3", features = ["no-recursion-limit"] }
 prost-types = "0.12.3"
 rayon = "1.10.0"

diff --git a/rust/sdk-processor/src/steps/common/latest_processed_version_tracker.rs b/rust/sdk-processor/src/steps/common/latest_processed_version_tracker.rs
@@ -105,12 +105,12 @@ where
         &mut self,
         current_batch: TransactionContext<T>,
     ) -> Result<Option<TransactionContext<T>>, ProcessorError> {
-        info!(
-            start_version = current_batch.start_version,
-            end_version = current_batch.end_version,
-            step_name = self.name(),
-            "Processing versions"
-        );
+        // info!(
+        //     start_version = current_batch.start_version,
+        //     end_version = current_batch.end_version,
+        //     step_name = self.name(),
+        //     "Processing versions"
+        // );
         // If there's a gap in the next_version and current_version, save the current_version to seen_versions for
         // later processing.
         if self.next_version != current_batch.start_version {
@@ -130,7 +130,7 @@ where
                     total_size_in_bytes: current_batch.total_size_in_bytes,
                 });
         } else {
-            info!("No gap detected");
+            // info!("No gap detected");
             // If the current_batch is the next expected version, update the last success batch
             self.update_last_success_batch(TransactionContext {
                 data: vec![], // No data is needed for tracking. This is to avoid clone.

diff --git a/rust/sdk-processor/src/steps/events_processor/events_extractor.rs b/rust/sdk-processor/src/steps/events_processor/events_extractor.rs
@@ -7,7 +7,7 @@ use aptos_indexer_processor_sdk::{
 };
 use async_trait::async_trait;
 use rayon::prelude::*;
-use tracing::{info, warn};
+use tracing::warn;
 
 pub const MIN_TRANSACTIONS_PER_RAYON_JOB: usize = 64;
 
@@ -25,12 +25,12 @@ impl Processable for EventsExtractor {
         &mut self,
         item: TransactionContext<Transaction>,
     ) -> Result<Option<TransactionContext<EventModel>>, ProcessorError> {
-        info!(
-            start_version = item.start_version,
-            end_version = item.end_version,
-            step_name = self.name(),
-            "Processing versions",
-        );
+        // info!(
+        //     start_version = item.start_version,
+        //     end_version = item.end_version,
+        //     step_name = self.name(),
+        //     "Processing versions",
+        // );
         let events = item
             .data
             .par_iter()

diff --git a/rust/sdk-processor/src/steps/events_processor/events_storer.rs b/rust/sdk-processor/src/steps/events_processor/events_storer.rs
@@ -66,12 +66,12 @@ impl Processable for EventsStorer {
         &mut self,
         events: TransactionContext<EventModel>,
     ) -> Result<Option<TransactionContext<EventModel>>, ProcessorError> {
-        tracing::info!(
-            start_version = events.start_version,
-            end_version = events.end_version,
-            step_name = self.name(),
-            "Processing versions",
-        );
+        // tracing::info!(
+        //     start_version = events.start_version,
+        //     end_version = events.end_version,
+        //     step_name = self.name(),
+        //     "Processing versions",
+        // );
         let per_table_chunk_sizes: AHashMap<String, usize> =
             self.processor_config.per_table_chunk_sizes.clone();
         let execute_res = execute_in_chunks(