add defensive check for from_converse response

Author: liustve

CHANGELOG.md

@@ -42,6 +42,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Fixed
 
+- `opentelemetry-instrumentation-botocore`: bedrock: Add safety check for bedrock ConverseStream responses
+  ([#3990](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/TBD))
 - `opentelemetry-instrumentation-botocore`: bedrock: only decode JSON input buffer in Anthropic Claude streaming
   ([#3875](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/3875))
 - `opentelemetry-instrumentation-aiohttp-client`, `opentelemetry-instrumentation-aiohttp-server`: Fix readme links and text

instrumentation/opentelemetry-instrumentation-botocore/tests/test_botocore_bedrock.py

@@ -3050,21 +3050,23 @@ def stream_error_callback(exc, ended):
         assert isinstance(tool_block["input"], dict)
     else:
         assert "input" not in tool_block
-def test_converse_stream_with_malformed_response():
+
+
+def test_converse_stream_with_missing_output_in_response():
     """Test that converse stream handles malformed response missing output key."""
+
     def stream_done_callback(response, ended):
         pass
-    
+
     wrapper = ConverseStreamWrapper(
         stream=mock.MagicMock(),
         stream_done_callback=stream_done_callback,
         model_id="amazon.nova-micro-v1:0",
     )
-    
-    malformed_response = {"stopReason": "end_turn"}
-    result = wrapper._complete_stream(malformed_response)
+
+    bedrock_response = {"stopReason": "end_turn"}
+    result = wrapper._complete_stream(bedrock_response)
     assert result is None
-    
 
 def amazon_nova_messages():
     return [