fix durations

sift-stack · Jan 27, 2025 · 84f1f33 · 84f1f33
1 parent d18b9a4
commit 84f1f33
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/rust/examples/ingestion/data.rs b/rust/examples/ingestion/data.rs
@@ -32,7 +32,7 @@ impl DataSource {
         let (data_tx, data_rx) = channel(1);
 
         let task_handler = task::spawn_blocking(move || {
-            let duration = Duration::from_secs(180);
+            let duration = Duration::from_secs(60);
             let start = Instant::now();
             let mut rng = rand::thread_rng();
 

diff --git a/rust/examples/ingestion/main.rs b/rust/examples/ingestion/main.rs
@@ -43,7 +43,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
     let run = create_run(grpc_channel.clone(), ASSET_NAME).await?;
     println!("initialized run {}", &run.name);
 
-    // Initialize the data source
+    // Initialize the data source which is an impl Stream
     let data_source = DataSource::new(ingestion_config, run);
 
     IngestServiceClient::new(grpc_channel)