From fc84f9e0ded9001f3a99a4469ea7cc0130802f2a Mon Sep 17 00:00:00 2001
From: kerry <kerry@berri.ai>
Date: Tue, 22 Sep 2026 21:32:45 +0000
Subject: [PATCH] test(integration): prefixed Opus 4.8 reasoning_effort reaches
 Bedrock as adaptive thinking (Pylon #7586)

Co-Authored-By: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com>
---
 tests/integration/contracts.json              |  3 +
 .../test_bedrock_claude_thinking_wire.py      | 60 +++++++++++++++++++
 2 files changed, 63 insertions(+)
 create mode 100644 tests/integration/providers/test_bedrock_claude_thinking_wire.py

diff --git a/tests/integration/contracts.json b/tests/integration/contracts.json
index d12e3ae4620..777fdea6243 100644
--- a/tests/integration/contracts.json
+++ b/tests/integration/contracts.json
@@ -128,6 +128,9 @@
     "tests/integration/providers/test_bedrock_auth_wire.py::test_bearer_environment_reference_loads_from_db_and_yaml_and_survives_reload": [
       "other.provider_wire.bedrock.bearer_db_yaml_survives_reload"
     ],
+    "tests/integration/providers/test_bedrock_claude_thinking_wire.py::test_prefixed_opus_4_8_reasoning_effort_reaches_bedrock_as_adaptive_thinking_not_budget_tokens": [
+      "other.provider_wire.bedrock.prefixed_opus_4_8_reasoning_effort_sends_adaptive_thinking"
+    ],
     "tests/integration/streaming/test_stream_contracts.py::test_generated_tcp_partitions_preserve_unicode_text_identity_and_final_usage": [
       "other.streaming.byte_partitions.preserve_text_identity_and_usage"
     ],
diff --git a/tests/integration/providers/test_bedrock_claude_thinking_wire.py b/tests/integration/providers/test_bedrock_claude_thinking_wire.py
new file mode 100644
index 00000000000..d3673a55660
--- /dev/null
+++ b/tests/integration/providers/test_bedrock_claude_thinking_wire.py
@@ -0,0 +1,60 @@
+import json
+from typing import Final
+
+import pytest
+from integration._support.client import Gateway
+from integration._support.wire import Reply, Request, wire_server
+
+MODEL: Final = "bedrock/invoke/us.anthropic.claude-opus-4-8"
+TOKEN: Final = "synthetic-bedrock-bearer"
+RESPONSE: Final = json.dumps(
+    {
+        "id": "msg_adaptive_control",
+        "type": "message",
+        "role": "assistant",
+        "model": "us.anthropic.claude-opus-4-8",
+        "content": [{"type": "text", "text": "adaptive thinking control"}],
+        "stop_reason": "end_turn",
+        "stop_sequence": None,
+        "usage": {"input_tokens": 12, "output_tokens": 5},
+    }
+).encode()
+
+
+def adaptive_peer(request: Request) -> Reply:
+    assert request.method == "POST" and request.target == "/model/us.anthropic.claude-opus-4-8/invoke"
+    assert request.headers["authorization"] == f"Bearer {TOKEN}"
+    body: Final = json.loads(request.body)
+    assert body["messages"] == [{"role": "user", "content": [{"type": "text", "text": "synthetic effort request"}]}]
+    assert body["thinking"]["type"] == "adaptive", body
+    assert body["output_config"] == {"effort": "high"}, body
+    assert "budget_tokens" not in json.dumps(body), body
+    return Reply(body=RESPONSE)
+
+
+@pytest.mark.covers("other.provider_wire.bedrock.prefixed_opus_4_8_reasoning_effort_sends_adaptive_thinking")
+def test_prefixed_opus_4_8_reasoning_effort_reaches_bedrock_as_adaptive_thinking_not_budget_tokens(
+    gateway: Gateway,
+) -> None:
+    with wire_server(adaptive_peer) as wire, gateway.scenario() as scenario:
+        model: Final = scenario.model(
+            model=MODEL,
+            api_key=TOKEN,
+            aws_region_name="us-east-1",
+            api_base=wire.url,
+            aws_bedrock_runtime_endpoint=wire.url,
+        )
+        response: Final = gateway.request(
+            "POST",
+            "/v1/chat/completions",
+            {
+                "model": model,
+                "messages": [{"role": "user", "content": "synthetic effort request"}],
+                "max_tokens": 4096,
+                "reasoning_effort": "high",
+            },
+        )
+        assert response.status_code == 200, response.text
+        assert response.json()["choices"][0]["message"]["content"] == "adaptive thinking control"
+        assert response.json()["usage"]["prompt_tokens"] == 12 and response.json()["usage"]["completion_tokens"] == 5
+        assert len(wire.drain()) == 1