fix missing field

crates/cli/src/args.rs

@@ -107,9 +107,8 @@ pub struct Args {
     pub initial_backoff: u64,
 
     /// The number of compute units per second for this provider
-    #[arg(long, default_value_t = 50, value_name = "U", help_heading="Acquisition Options")]
-    pub  compute_units_per_second: u64,
-
+    #[arg(long, default_value_t = 50, value_name = "U", help_heading = "Acquisition Options")]
+    pub compute_units_per_second: u64,
 
     /// Global number of concurrent requests
     #[arg(long, value_name = "M", help_heading = "Acquisition Options")]

crates/cli/src/parse/timestamps.rs

@@ -324,7 +324,11 @@ async fn get_latest_timestamp(source: Arc<Source>) -> Result<u64, ParseError> {
 mod tests {
     use std::num::NonZeroU32;
 
-    use alloy::{providers::ProviderBuilder, rpc::client::{BuiltInConnectionString, ClientBuilder, RpcClient}, transports::{layers::RetryBackoffLayer, BoxTransport}};
+    use alloy::{
+        providers::ProviderBuilder,
+        rpc::client::{BuiltInConnectionString, ClientBuilder, RpcClient},
+        transports::{layers::RetryBackoffLayer, BoxTransport},
+    };
     use governor::{Quota, RateLimiter};
 
     use super::*;
@@ -339,8 +343,10 @@ mod tests {
         let initial_backoff = 500;
         let compute_units_per_second = 50;
         let max_concurrent_requests = 100;
-        let retry_layer = RetryBackoffLayer::new(max_retry, initial_backoff, compute_units_per_second);
-        let connect: BuiltInConnectionString = rpc_url.parse().map_err(ParseError::ProviderError).unwrap();
+        let retry_layer =
+            RetryBackoffLayer::new(max_retry, initial_backoff, compute_units_per_second);
+        let connect: BuiltInConnectionString =
+            rpc_url.parse().map_err(ParseError::ProviderError).unwrap();
         let client: RpcClient<BoxTransport> = ClientBuilder::default()
             .layer(retry_layer)
             .connect_boxed(connect)

crates/python/rust/collect_adapter.rs

@@ -31,6 +31,7 @@ use cryo_freeze::collect;
         chunk_order = None,
         max_retries = 10,
         initial_backoff = 500,
+        compute_units_per_second = 50,
         dry = false,
         chunk_size = 1000,
         n_chunks = None,
@@ -92,6 +93,7 @@ pub fn _collect(
     chunk_order: Option<String>,
     max_retries: u32,
     initial_backoff: u64,
+    compute_units_per_second: u64,
     dry: bool,
     chunk_size: u64,
     n_chunks: Option<u64>,
@@ -157,6 +159,7 @@ pub fn _collect(
             chunk_order,
             max_retries,
             initial_backoff,
+            compute_units_per_second,
             dry,
             chunk_size,
             n_chunks,

crates/python/rust/freeze_adapter.rs

@@ -28,6 +28,7 @@ use cryo_cli::{run, Args};
         chunk_order = None,
         max_retries = 10,
         initial_backoff = 500,
+        compute_units_per_second = 50,
         dry = false,
         chunk_size = 1000,
         n_chunks = None,
@@ -89,6 +90,7 @@ pub fn _freeze(
     chunk_order: Option<String>,
     max_retries: u32,
     initial_backoff: u64,
+    compute_units_per_second: u64,
     dry: bool,
     chunk_size: u64,
     n_chunks: Option<u64>,
@@ -149,6 +151,7 @@ pub fn _freeze(
             chunk_order,
             max_retries,
             initial_backoff,
+            compute_units_per_second,
             dry,
             chunk_size,
             n_chunks,