diff --git a/rust/crates/langsmith_tracing_client/Cargo.toml b/rust/crates/langsmith_tracing_client/Cargo.toml index 09398479d..2814b34b1 100644 --- a/rust/crates/langsmith_tracing_client/Cargo.toml +++ b/rust/crates/langsmith_tracing_client/Cargo.toml @@ -23,4 +23,4 @@ criterion = { version = "0.5.1", features = ["async_tokio"] } [[bench]] name = "tracing_client_benchmark" -harness = false \ No newline at end of file +harness = false diff --git a/rust/crates/langsmith_tracing_client/benches/tracing_client_benchmark.rs b/rust/crates/langsmith_tracing_client/benches/tracing_client_benchmark.rs index fcd29740f..c142706c4 100644 --- a/rust/crates/langsmith_tracing_client/benches/tracing_client_benchmark.rs +++ b/rust/crates/langsmith_tracing_client/benches/tracing_client_benchmark.rs @@ -158,7 +158,6 @@ fn bench_run_create_iter_custom(c: &mut Criterion) { let mut elapsed_time = Duration::default(); let server_url = server_url.clone(); async move { - println!("Iterations: {}", iters); for _ in 0..iters { let runs: Vec = (0..num_runs) .map(|i| { @@ -181,10 +180,8 @@ fn bench_run_create_iter_custom(c: &mut Criterion) { } // shutdown the client to flush the queue client.shutdown().await.unwrap(); - println!("Elapsed time inner loop: {:?}", start.elapsed()); elapsed_time += start.elapsed(); } - println!("Elapsed time: {:?}", elapsed_time); elapsed_time } }) @@ -199,7 +196,7 @@ fn bench_run_create_iter_custom(c: &mut Criterion) { criterion_group! { name = benches; config = Criterion::default().sample_size(10); - targets = bench_run_create_iter_custom, bench_run_create + targets = bench_run_create } criterion_main!(benches); diff --git a/rust/crates/langsmith_tracing_client/src/client/processor.rs b/rust/crates/langsmith_tracing_client/src/client/processor.rs index bcee346bd..de236c652 100644 --- a/rust/crates/langsmith_tracing_client/src/client/processor.rs +++ b/rust/crates/langsmith_tracing_client/src/client/processor.rs @@ -85,6 +85,7 @@ impl RunProcessor { async fn send_batch(&self, batch: Vec) -> Result<(), TracingClientError> { let mut form = Form::new(); + // println!("Sending batch of {} runs", batch.len()); for queued_run in batch { match queued_run {