diff --git a/src/fortifyroot/_vendor/VENDOR_DEPENDENCIES.json b/src/fortifyroot/_vendor/VENDOR_DEPENDENCIES.json
index f4a8222..9654231 100644
--- a/src/fortifyroot/_vendor/VENDOR_DEPENDENCIES.json
+++ b/src/fortifyroot/_vendor/VENDOR_DEPENDENCIES.json
@@ -52,7 +52,7 @@
   },
   "test": {
     "anthropic": ">=0.25.2,<0.83.0",
-    "boto3": ">=1.35.49,<2",
+    "boto3": ">=1.34.120,<2",
     "chromadb": ">=0.5.23,<0.6.0",
     "google-genai": ">=1.58.0,<1.59.0",
     "langchain": ">=1.0.0,<2.0.0",
diff --git a/src/fortifyroot/_vendor/VENDOR_MANIFEST.json b/src/fortifyroot/_vendor/VENDOR_MANIFEST.json
index 0c6f09c..a6d6dc2 100644
--- a/src/fortifyroot/_vendor/VENDOR_MANIFEST.json
+++ b/src/fortifyroot/_vendor/VENDOR_MANIFEST.json
@@ -1,9 +1,9 @@
 {
-  "vendored_at": "2026-06-20T15:30:40.858037",
+  "vendored_at": "2026-06-20T23:35:14.965076",
   "openllmetry_version": "0.52.6",
-  "git_commit": "4197aa45893b",
+  "git_commit": "0d03c3f8fba0",
   "git_branch": "HEAD",
-  "git_tag": "fr-v0.52.6.31",
+  "git_tag": "fr-v0.52.6.32",
   "instrumentation_package_policy": {
     "opentelemetry-instrumentation-agno": false,
     "opentelemetry-instrumentation-alephalpha": false,
diff --git a/src/fortifyroot/_vendor/opentelemetry/instrumentation/anthropic/streaming.py b/src/fortifyroot/_vendor/opentelemetry/instrumentation/anthropic/streaming.py
index fddd9eb..d514ef0 100644
--- a/src/fortifyroot/_vendor/opentelemetry/instrumentation/anthropic/streaming.py
+++ b/src/fortifyroot/_vendor/opentelemetry/instrumentation/anthropic/streaming.py
@@ -304,7 +304,6 @@ def __next__(self):  # FR: rewritten for pending-item safety buffer
                     self._instrumentation_completed = True
                 raise e
 
-            item = self._streaming_safety.process_item(item)  # FR: streaming safety processing
             if self._first_token_time is None and _is_streaming_token_item(item):
                 self._first_token_time = time.perf_counter()
                 _set_streaming_first_token_latency(
@@ -312,6 +311,7 @@ def __next__(self):  # FR: rewritten for pending-item safety buffer
                     self._start_time,
                     self._first_token_time,
                 )
+            item = self._streaming_safety.process_item(item)  # FR: streaming safety processing
             if self._pending_item is None:  # FR: pending-item buffer logic
                 self._pending_item = item  # FR: pending-item buffer logic
                 continue  # FR: pending-item buffer logic
@@ -508,7 +508,6 @@ async def __anext__(self):  # FR: rewritten for pending-item safety buffer
                     self._instrumentation_completed = True
                 raise
 
-            item = self._streaming_safety.process_item(item)  # FR: streaming safety processing
             if self._first_token_time is None and _is_streaming_token_item(item):
                 self._first_token_time = time.perf_counter()
                 _set_streaming_first_token_latency(
@@ -516,6 +515,7 @@ async def __anext__(self):  # FR: rewritten for pending-item safety buffer
                     self._start_time,
                     self._first_token_time,
                 )
+            item = self._streaming_safety.process_item(item)  # FR: streaming safety processing
             if self._pending_item is None:  # FR: pending-item buffer logic
                 self._pending_item = item  # FR: pending-item buffer logic
                 continue  # FR: pending-item buffer logic