From 94d8de967f8ae969e2b2b3b118b0fde006e5755d Mon Sep 17 00:00:00 2001
From: Daniel Piet <dp@openai.com>
Date: Thu, 10 Sep 2026 13:32:52 -0700
Subject: [PATCH 1/2] fix: allow longer timeout for large Agents stream test

---
 .../services/beta/agents/AgentSessionStreamTest.kt    | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/openai-java-core/src/test/kotlin/com/openai/services/beta/agents/AgentSessionStreamTest.kt b/openai-java-core/src/test/kotlin/com/openai/services/beta/agents/AgentSessionStreamTest.kt
index 676b229ed..f833ac311 100644
--- a/openai-java-core/src/test/kotlin/com/openai/services/beta/agents/AgentSessionStreamTest.kt
+++ b/openai-java-core/src/test/kotlin/com/openai/services/beta/agents/AgentSessionStreamTest.kt
@@ -198,14 +198,13 @@ internal class AgentSessionStreamTest {
         t: Transport,
         async: Boolean,
         params: AgentSessionStreamParams = params().build(),
+        requestTimeout: Duration = Duration.ofSeconds(9),
+        completionTimeoutSeconds: Long = 10,
         action: (AgentSessionEvent) -> Unit = {},
     ): List<AgentSessionEvent> {
         val events = mutableListOf<AgentSessionEvent>()
         val options =
-            RequestOptions.builder()
-                .timeout(Duration.ofSeconds(9))
-                .responseValidation(false)
-                .build()
+            RequestOptions.builder().timeout(requestTimeout).responseValidation(false).build()
         val client = t.client()
         if (async)
             client
@@ -219,7 +218,7 @@ internal class AgentSessionStreamTest {
                     action(it)
                 }
                 .onCompleteFuture()
-                .get(10, TimeUnit.SECONDS)
+                .get(completionTimeoutSeconds, TimeUnit.SECONDS)
         else
             client.beta().agents().sessions().stream(params, options).use {
                 it.stream().forEach {
@@ -793,6 +792,8 @@ internal class AgentSessionStreamTest {
                             null
                         }
                         .build(),
+                    requestTimeout = Duration.ofSeconds(60),
+                    completionTimeoutSeconds = 70,
                 )
             )
             .hasSize(events.size)

From 49c4d117ef2b4aba683ecc1bf62a5f5deafcdef3 Mon Sep 17 00:00:00 2001
From: Daniel Piet <dp@openai.com>
Date: Thu, 10 Sep 2026 13:37:48 -0700
Subject: [PATCH 2/2] fix: preserve request timeout in large stream test

---
 .../openai/services/beta/agents/AgentSessionStreamTest.kt  | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/openai-java-core/src/test/kotlin/com/openai/services/beta/agents/AgentSessionStreamTest.kt b/openai-java-core/src/test/kotlin/com/openai/services/beta/agents/AgentSessionStreamTest.kt
index f833ac311..013075b0f 100644
--- a/openai-java-core/src/test/kotlin/com/openai/services/beta/agents/AgentSessionStreamTest.kt
+++ b/openai-java-core/src/test/kotlin/com/openai/services/beta/agents/AgentSessionStreamTest.kt
@@ -198,13 +198,15 @@ internal class AgentSessionStreamTest {
         t: Transport,
         async: Boolean,
         params: AgentSessionStreamParams = params().build(),
-        requestTimeout: Duration = Duration.ofSeconds(9),
         completionTimeoutSeconds: Long = 10,
         action: (AgentSessionEvent) -> Unit = {},
     ): List<AgentSessionEvent> {
         val events = mutableListOf<AgentSessionEvent>()
         val options =
-            RequestOptions.builder().timeout(requestTimeout).responseValidation(false).build()
+            RequestOptions.builder()
+                .timeout(Duration.ofSeconds(9))
+                .responseValidation(false)
+                .build()
         val client = t.client()
         if (async)
             client
@@ -792,7 +794,6 @@ internal class AgentSessionStreamTest {
                             null
                         }
                         .build(),
-                    requestTimeout = Duration.ofSeconds(60),
                     completionTimeoutSeconds = 70,
                 )
             )