lint

rust/indexer-metrics/src/main.rs

@@ -159,7 +159,10 @@ async fn start_processor_status_fetch(url: String, chain_name: String) {
  HASURA_API_LATEST_TRANSACTION_TIMESTAMP
  .with_label_values(&[&processor.processor, &chain_name])
  .set(
- processor.last_transaction_timestamp.and_utc().timestamp_micros() as f64
+ processor
+ .last_transaction_timestamp
+ .and_utc()
+ .timestamp_micros() as f64
  * 1e-6,
  );
  let latency = system_time_now - processor.last_transaction_timestamp;

rust/processor/src/bq_analytics/generic_parquet_processor.rs

@@ -78,7 +78,11 @@ fn create_new_writer(
  .set_compression(parquet::basic::Compression::LZ4)
  .build();
  let props_arc = Arc::new(props);
- let file: File = File::options().create(true).write(true).open(file_path)?;
+ let file: File = File::options()
+ .create(true)
+ .truncate(true)
+ .write(true)
+ .open(file_path)?;
 
  Ok(SerializedFileWriter::new(
  file.try_clone()?,

rust/processor/src/processors/mod.rs

@@ -205,10 +205,7 @@ impl ProcessorConfig {
  }
 
  pub fn is_parquet_processor(&self) -> bool {
- match self {
- ProcessorConfig::DefaultParquetProcessor(_) => true,
- _ => false,
- }
+ matches!(self, ProcessorConfig::DefaultParquetProcessor(_))
  }
 }
 

rust/processor/src/utils/util.rs

@@ -514,14 +514,14 @@ mod tests {
  },
  1,
  );
- assert_eq!(ts.timestamp(), 1649560602);
+ assert_eq!(ts.and_utc().timestamp(), 1649560602);
  assert_eq!(ts.year(), 2022);
 
  let ts2 = parse_timestamp_secs(600000000000000, 2);
  assert_eq!(ts2.year(), 9999);
 
  let ts3 = parse_timestamp_secs(1659386386, 2);
- assert_eq!(ts3.timestamp(), 1659386386);
+ assert_eq!(ts3.and_utc().timestamp(), 1659386386);
  }
 
  #[test]