feat: support redactedContent in reasoningContent streamed events

src/strands/event_loop/streaming.py

@@ -153,6 +153,18 @@ def handle_content_block_delta(
                 **kwargs,
             )
 
+        elif "redactedContent" in delta_content["reasoningContent"]:
+            if "redactedContent" not in state:
+                state["redactedContent"] = b""
+
+            state["redactedContent"] += delta_content["reasoningContent"]["redactedContent"]
+            callback_handler(
+                redactedContent=delta_content["reasoningContent"]["redactedContent"],
+                delta=delta_content,
+                reasoning=True,
+                **kwargs,
+            )
+
     return state
 
 
@@ -207,6 +219,9 @@ def handle_content_block_stop(state: Dict[str, Any]) -> Dict[str, Any]:
             }
         )
         state["reasoningText"] = ""
+    elif "redactedContent" in state and state["redactedContent"]:
+        content.append({"reasoningContent": {"redactedContent": state["redactedContent"]}})
+        state["redactedContent"] = b""
 
     return state
 
@@ -279,6 +294,7 @@ def process_stream(
         "current_tool_use": {},
         "reasoningText": "",
         "signature": "",
+        "redactedContent": b"",
     }
     state["content"] = state["message"]["content"]
 

tests/strands/event_loop/test_streaming.py

@@ -132,6 +132,20 @@ def test_handle_content_block_start(chunk: ContentBlockStartEvent, exp_tool_use)
             {"signature": "val"},
             {"reasoning_signature": "val", "reasoning": True},
         ),
+        # Reasoning - redactedContent - New
+        (
+            {"delta": {"reasoningContent": {"redactedContent": b"encrypted"}}},
+            {},
+            {"redactedContent": b"encrypted"},
+            {"redactedContent": b"encrypted", "reasoning": True},
+        ),
+        # Reasoning - redactedContent - Existing
+        (
+            {"delta": {"reasoningContent": {"redactedContent": b"data"}}},
+            {"redactedContent": b"encrypted_"},
+            {"redactedContent": b"encrypted_data"},
+            {"redactedContent": b"data", "reasoning": True},
+        ),
         # Reasoning - Empty
         (
             {"delta": {"reasoningContent": {}}},
@@ -230,6 +244,23 @@ def callback_handler(**kwargs):
                 "signature": "123",
             },
         ),
+        # redactedContent
+        (
+            {
+                "content": [],
+                "current_tool_use": {},
+                "text": "",
+                "reasoningText": "",
+                "redactedContent": b"encrypted_data",
+            },
+            {
+                "content": [{"reasoningContent": {"redactedContent": b"encrypted_data"}}],
+                "current_tool_use": {},
+                "text": "",
+                "reasoningText": "",
+                "redactedContent": b"",
+            },
+        ),
         # Empty
         (
             {
@@ -355,6 +386,36 @@ def test_extract_usage_metrics():
             {"calls": 1},
             [{"role": "user", "content": [{"text": "REDACTED"}]}],
         ),
+        (
+            [
+                {"messageStart": {"role": "assistant"}},
+                {
+                    "contentBlockStart": {"start": {}},
+                },
+                {
+                    "contentBlockDelta": {"delta": {"reasoningContent": {"redactedContent": b"encrypted_data"}}},
+                },
+                {"contentBlockStop": {}},
+                {
+                    "messageStop": {"stopReason": "end_turn"},
+                },
+                {
+                    "metadata": {
+                        "usage": {"inputTokens": 1, "outputTokens": 1, "totalTokens": 1},
+                        "metrics": {"latencyMs": 1},
+                    }
+                },
+            ],
+            "end_turn",
+            {
+                "role": "assistant",
+                "content": [{"reasoningContent": {"redactedContent": b"encrypted_data"}}],
+            },
+            {"inputTokens": 1, "outputTokens": 1, "totalTokens": 1},
+            {"latencyMs": 1},
+            {"calls": 1},
+            [{"role": "user", "content": [{"text": "Some input!"}]}],
+        ),
     ],
 )
 def test_process_stream(