Log agent job concurrency

This commit is contained in:
Dave Aitel
2026-02-06 12:37:40 -05:00
parent 9f1e7671fb
commit 4717f0c5b8
2 changed files with 10 additions and 0 deletions

View File

@@ -28,6 +28,7 @@ use std::path::PathBuf;
use std::sync::Arc;
use tokio::time::Duration;
use tokio::time::Instant;
use tracing::info;
use uuid::Uuid;
pub struct AgentJobsHandler;
@@ -308,6 +309,13 @@ mod spawn_agents_on_csv {
))
})?;
let options = build_runner_options(&session, &turn, args.max_concurrency).await?;
info!(
job_id = %job_id,
requested_concurrency = ?args.max_concurrency,
max_threads = ?turn.config.agent_max_threads,
effective_concurrency = options.max_concurrency,
"agent job concurrency"
);
if let Err(err) = run_agent_job_loop(
session.clone(),
turn.clone(),

View File

@@ -865,6 +865,8 @@ impl EventProcessorWithHumanOutput {
matches!(
msg,
EventMsg::ThreadNameUpdated(_)
| EventMsg::TokenCount(_)
| EventMsg::TurnStarted(_)
| EventMsg::ExecApprovalRequest(_)
| EventMsg::ApplyPatchApprovalRequest(_)
| EventMsg::TerminalInteraction(_)