diff --git a/codex-rs/core/src/tools/handlers/agent_jobs.rs b/codex-rs/core/src/tools/handlers/agent_jobs.rs index fd5e54d72c..ff27f7c9d4 100644 --- a/codex-rs/core/src/tools/handlers/agent_jobs.rs +++ b/codex-rs/core/src/tools/handlers/agent_jobs.rs @@ -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(), diff --git a/codex-rs/exec/src/event_processor_with_human_output.rs b/codex-rs/exec/src/event_processor_with_human_output.rs index 6ced035793..b95517c0a8 100644 --- a/codex-rs/exec/src/event_processor_with_human_output.rs +++ b/codex-rs/exec/src/event_processor_with_human_output.rs @@ -865,6 +865,8 @@ impl EventProcessorWithHumanOutput { matches!( msg, EventMsg::ThreadNameUpdated(_) + | EventMsg::TokenCount(_) + | EventMsg::TurnStarted(_) | EventMsg::ExecApprovalRequest(_) | EventMsg::ApplyPatchApprovalRequest(_) | EventMsg::TerminalInteraction(_)