rebase

aptos-labs · Jul 25, 2024 · 6a481af · 6a481af
1 parent 860cdcb
commit 6a481af
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 9 deletions.
diff --git a/rust/processor/src/db/common/models/ans_models/parquet_ans_lookup_v2.rs b/rust/processor/src/db/common/models/ans_models/parquet_ans_lookup_v2.rs
@@ -34,9 +34,6 @@ pub struct AnsPrimaryNameV2 {
     pub token_name: Option<String>,
     pub is_deleted: bool,
     #[allocative(skip)]
-    pub expiration_timestamp: chrono::NaiveDateTime,
-    pub subdomain_expiration_policy: Option<i64>,
-    #[allocative(skip)]
     pub block_timestamp: chrono::NaiveDateTime,
 }
 
@@ -65,8 +62,6 @@ pub struct CurrentAnsPrimaryNameV2 {
     pub token_name: Option<String>,
     pub is_deleted: bool,
     pub last_transaction_version: i64,
-    pub expiration_timestamp: chrono::NaiveDateTime,
-    pub subdomain_expiration_policy: Option<i64>,
 }
 
 impl Ord for CurrentAnsPrimaryNameV2 {
@@ -106,8 +101,6 @@ impl CurrentAnsPrimaryNameV2 {
                 subdomain: v1_primary_name.subdomain,
                 token_name: v1_primary_name.token_name,
                 is_deleted: v1_primary_name.is_deleted,
-                // expiration_timestamp: v1_primary_name.expiration_timestamp,
-                // subdomain_expiration_policy: v1_primary_name.subdomain_expiration_policy,
                 block_timestamp,
             },
         )

diff --git a/rust/processor/src/processors/parquet_processors/parquet_ans_processor.rs b/rust/processor/src/processors/parquet_processors/parquet_ans_processor.rs
@@ -116,7 +116,6 @@ impl ProcessorTrait for ParquetAnsProcessor {
 
         let ans_primary_name_v2_parquet_data = ParquetDataGeneric {
             data: all_ans_primary_names_v2,
-            transaction_version_to_struct_count: transaction_version_to_struct_count.clone(),
         };
 
         self.ans_primary_name_v2_sender
@@ -129,7 +128,9 @@ impl ProcessorTrait for ParquetAnsProcessor {
                 start_version: start_version as i64,
                 end_version: end_version as i64,
                 last_transaction_timestamp: last_transaction_timestamp.clone(),
-                txn_version_to_struct_count: AHashMap::new(),
+                txn_version_to_struct_count: Some(transaction_version_to_struct_count),
+                parquet_processed_structs: None,
+                table_name: "".to_string(),
             },
         ))
     }