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

Add jitter to deferred goal retries

Browse Source
This commit is contained in:
Eric Traut
2026-07-08 16:03:57 -07:00
parent c20cab2606
commit b5156738f6
3 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
codex-rs/Cargo.lock generated
View File

@@ -3160,6 +3160,7 @@ dependencies = [
"codex-tools",
"codex-utils-template",
"pretty_assertions",
"rand 0.9.3",
"serde",
"serde_json",
"tempfile",

1
codex-rs/ext/goal/Cargo.toml
View File

@@ -22,6 +22,7 @@ codex-protocol = { workspace = true }
codex-state = { workspace = true }
codex-tools = { workspace = true }
codex-utils-template = { workspace = true }
rand = { workspace = true }
serde = { workspace = true, features = ["derive"] }
serde_json = { workspace = true }
tokio = { workspace = true, features = ["sync"] }

12
codex-rs/ext/goal/src/extension.rs
View File

@@ -32,6 +32,7 @@ use codex_protocol::protocol::SessionSource;
use codex_protocol::protocol::SubAgentSource;
use codex_protocol::protocol::ThreadGoalStatus;
use codex_protocol::protocol::TokenUsageInfo;
use rand::Rng;
use crate::accounting::BudgetLimitedGoalDisposition;
use crate::accounting::GoalAccountingState;
@@ -46,9 +47,10 @@ use crate::spec::UPDATE_GOAL_TOOL_NAME;
use crate::steering::budget_limit_steering_item;
use crate::tool::GoalToolExecutor;
// Capacity failures do not consume user tokens, but retrying immediately can
// create a tight loop. Keep the retry cadence deliberately low.
const DEFERRED_GOAL_RETRY_DELAY: Duration = Duration::from_secs(5 * 60);
// Capacity failures do not consume user tokens. Add jitter around a five-minute
// average so clients that hit capacity together do not retry in lockstep.
const DEFERRED_GOAL_RETRY_MIN_SECS: u64 = 4 * 60;
const DEFERRED_GOAL_RETRY_MAX_SECS: u64 = 6 * 60;
#[derive(Clone, Debug)]
pub struct GoalExtensionConfig {
@@ -313,7 +315,9 @@ where
.accounting_state()
.turn_is_current_active_goal(input.turn_id)
{
return Some(DEFERRED_GOAL_RETRY_DELAY);
return Some(Duration::from_secs(rand::rng().random_range(
DEFERRED_GOAL_RETRY_MIN_SECS..=DEFERRED_GOAL_RETRY_MAX_SECS,
)));
}
let reason = match input.error {
CodexErrorInfo::UsageLimitExceeded => ActiveGoalStopReason::UsageLimit,