R6

codex-rs/cli/src/infty/commands.rs

@@ -92,11 +92,12 @@ pub(crate) async fn run_create(
     };
 
     if let Some(objective) = args.objective {
-        let mut options = RunExecutionOptions::default();
-        options.objective = Some(objective);
         let timeout = Duration::from_secs(args.timeout_secs);
-        options.director_timeout = timeout;
-        options.verifier_timeout = timeout;
+        let options = RunExecutionOptions {
+            objective: Some(objective),
+            director_timeout: timeout,
+            verifier_timeout: timeout,
+        };
 
         let start = Instant::now();
         let start_header = format!("Starting run {run_id}");

codex-rs/codex-infty/tests/schemas.rs

@@ -67,8 +67,10 @@ async fn director_request_includes_output_schema() -> anyhow::Result<()> {
         verifiers: Vec::new(),
     };
 
-    let mut options = RunExecutionOptions::default();
-    options.objective = Some("Kick off".to_string());
+    let options = RunExecutionOptions {
+        objective: Some("Kick off".to_string()),
+        ..Default::default()
+    };
 
     // Drive the run in the background; we'll assert the request shape then cancel.
     let fut = tokio::spawn(async move {
@@ -164,8 +166,10 @@ async fn final_delivery_request_includes_output_schema() -> anyhow::Result<()> {
         verifiers: Vec::new(),
     };
 
-    let mut options = RunExecutionOptions::default();
-    options.objective = Some("Kick off".to_string());
+    let options = RunExecutionOptions {
+        objective: Some("Kick off".to_string()),
+        ..Default::default()
+    };
 
     let fut = tokio::spawn(async move {
         let _ = orchestrator.execute_new_run(params, options).await;
@@ -250,8 +254,10 @@ async fn verifier_request_includes_output_schema() -> anyhow::Result<()> {
         verifiers: vec![RoleConfig::new("verifier", verifier_config)],
     };
 
-    let mut options = RunExecutionOptions::default();
-    options.objective = Some("Kick off".to_string());
+    let options = RunExecutionOptions {
+        objective: Some("Kick off".to_string()),
+        ..Default::default()
+    };
 
     let fut = tokio::spawn(async move {
         let _ = orchestrator.execute_new_run(params, options).await;

codex-rs/codex-infty/tests/timeouts.rs

@@ -66,9 +66,11 @@ async fn direction_request_times_out_when_director_is_silent() -> anyhow::Result
         verifiers: Vec::new(),
     };
 
-    let mut options = RunExecutionOptions::default();
-    options.objective = Some("Kick off".to_string());
-    options.director_timeout = Duration::from_millis(50);
+    let options = RunExecutionOptions {
+        objective: Some("Kick off".to_string()),
+        director_timeout: Duration::from_millis(50),
+        ..Default::default()
+    };
 
     let err = orchestrator
         .execute_new_run(params, options)

codex-rs/codex-infty/tests/verifier_replacement.rs

@@ -98,8 +98,10 @@ async fn replaces_passing_verifiers_and_keeps_failing() -> anyhow::Result<()> {
         .and_then(|m| m.rollout_path.clone())
         .expect("beta initial rollout path");
 
-    let mut options = RunExecutionOptions::default();
-    options.verifier_timeout = Duration::from_secs(2);
+    let options = RunExecutionOptions {
+        verifier_timeout: Duration::from_secs(2),
+        ..Default::default()
+    };
 
     // Round 1: alpha pass (should be replaced), beta fail (should be kept)
     let _summary1 = orchestrator