rebase

aptos-labs · Jul 23, 2024 · 47ea58a · 47ea58a
1 parent c91c4c2
commit 47ea58a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/rust/processor/src/processors/parquet_processors/mod.rs b/rust/processor/src/processors/parquet_processors/mod.rs
@@ -12,9 +12,6 @@ pub trait ParquetProcessorTrait {
     fn set_google_credentials(&self, credentials: Option<String>) {
         if let Some(credentials) = credentials {
             std::env::set_var(GOOGLE_APPLICATION_CREDENTIALS, credentials);
-        } else {
-            tracing::error!("Google application credentials not set. Please set GOOGLE_APPLICATION_CREDENTIALS environment variable.");
-            panic!();
         }
     }
 }
diff --git a/rust/processor/src/processors/parquet_processors/parquet_events_processor.rs b/rust/processor/src/processors/parquet_processors/parquet_events_processor.rs
@@ -140,7 +140,6 @@ impl ProcessorTrait for ParquetEventsProcessor {
 
         let event_parquet_data = ParquetDataGeneric {
             data: events,
-            transaction_version_to_struct_count: AHashMap::new(),
         };
 
         self.event_sender
@@ -153,7 +152,9 @@ impl ProcessorTrait for ParquetEventsProcessor {
                 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(),
             },
         ))
     }