mirrors/codex
1
0
Fork 0
mirror of https://github.com/openai/codex.git synced 2026-04-27 09:51:03 +03:00
Code Issues Packages Projects Releases Wiki Activity

Emit agent job concurrency in output

Browse Source
This commit is contained in:
Dave Aitel
2026-02-06 12:43:06 -05:00
parent 4717f0c5b8
commit 23dd69ea9c
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
codex-rs/core/src/tools/handlers/agent_jobs.rs
View File

@@ -28,7 +28,6 @@ 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;
@@ -309,13 +308,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"
let requested_concurrency = args.max_concurrency;
let max_threads = turn.config.agent_max_threads;
let effective_concurrency = options.max_concurrency;
let message = format!(
"agent job concurrency: job_id={job_id} requested={requested_concurrency:?} max_threads={max_threads:?} effective={effective_concurrency}"
);
let _ = session.notify_background_event(&turn, message).await;
if let Err(err) = run_agent_job_loop(
session.clone(),
turn.clone(),