test(qa): use full-turn budget for native stop recovery

RomneyDa · RomneyDa · commit b191c2434f87 · 2026-07-03T15:14:26.000-07:00
diff --git a/qa/scenarios/channels/native-command-session-target.yaml b/qa/scenarios/channels/native-command-session-target.yaml
@@ -34,8 +34,6 @@ scenario:
       requiredProviderMode: mock-openai
       conversationId: native-stop-target
       senderId: qa-native-operator
-      warmupPrompt: "Reply exactly: QA-NATIVE-STOP-WARMUP-OK"
-      warmupMarker: QA-NATIVE-STOP-WARMUP-OK
       delayedPrompt: "Subagent recovery worker native command target proof. Wait until stopped."
       abortReplyNeedle: Agent was aborted
       recoveryMarker: QA-NATIVE-STOP-RECOVERY-OK
@@ -56,27 +54,6 @@ flow:
             - ref: env
             - 60000
         - resetTransport: true
-        # Gateway health intentionally precedes asynchronous provider/model warmups.
-        # Finish one real turn before timing active-run admission on a cold isolated worker.
-        - sendInbound:
-            conversation:
-              id:
-                expr: config.conversationId
-              kind: direct
-            senderId:
-              expr: config.senderId
-            senderName: QA Native Operator
-            text:
-              expr: config.warmupPrompt
-        - waitForOutbound:
-            conversation:
-              id:
-                expr: config.conversationId
-              kind: direct
-            textIncludes:
-              expr: config.warmupMarker
-            timeoutMs: 15000
-        - resetTransport: true
         - sendInbound:
             conversation:
               id:
@@ -118,15 +95,6 @@ flow:
               expr: config.abortReplyNeedle
             timeoutMs: 15000
           saveAs: abortReply
-        # The native acknowledgement confirms command handling, not session-lane release.
-        # Wait for the aborted run to clear before proving that the next turn is unblocked.
-        - call: waitForCondition
-          args:
-            - lambda:
-                async: true
-                expr: "env.gateway.call('sessions.list', {}).then((result) => result.sessions?.find((session) => session.key === activeSession.key && session.hasActiveRun !== true))"
-            - 30000
-            - 100
         - sendInbound:
             conversation:
               id:
@@ -146,6 +114,7 @@ flow:
               ref: startIndex
             textIncludes:
               expr: config.recoveryMarker
-            timeoutMs: 15000
+            timeoutMs:
+              expr: liveTurnTimeoutMs(env, 30000)
           saveAs: recoveryReply
       detailsExpr: "`native command reply=${abortReply.text}; recovery reply=${recoveryReply.text}`"
