From 1f1116ddde876615e5903f9684e5de41f447db37 Mon Sep 17 00:00:00 2001 From: AmarkFox Date: Sun, 12 Apr 2026 10:39:18 +0000 Subject: [PATCH] fix: log beta headers on 'invalid beta flag' error for faster diagnosis Problem: When Bedrock rejects a request with 'invalid beta flag', the error message does not indicate which specific beta header caused the failure. Diagnosing the issue requires manually searching CloudWatch logs for 'Passing through beta header' entries and cross-referencing timestamps, which is slow and error-prone. This is important because the proxy uses a passthrough-by-default strategy for unknown beta headers (to maximize feature compatibility), so new unsupported headers from Claude Code upgrades will occasionally cause this error until they are added to the blocklist. Change: Add targeted logging in both InvokeModel and InvokeModelWithResponseStream error handlers: when the error message contains 'invalid beta', log the full list of beta headers that were sent to Bedrock, plus the original anthropic-beta header from the client. Example log output on error: [ERROR] Code: ValidationException [ERROR] Message: invalid beta flag [ERROR] Beta headers sent: ['interleaved-thinking-2025-05-14', 'bad-header'] [ERROR] Original anthropic-beta header: interleaved-thinking-2025-05-14,bad-header,... Diagnosis workflow: 1. User reports 'invalid beta flag' error from Claude Code 2. Search CloudWatch: filter-pattern '"invalid beta"' 3. Log shows exactly which headers were sent 4. Add the offending header to blocklist via Admin Portal (Beta Headers management page, no redeployment needed) --- app/services/bedrock_service.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/app/services/bedrock_service.py b/app/services/bedrock_service.py index 22645d6..8cede85 100644 --- a/app/services/bedrock_service.py +++ b/app/services/bedrock_service.py @@ -893,7 +893,11 @@ def _invoke_model_native_sync( print(f"\n[ERROR] InvokeModel ClientError in request {request_id}") print(f"[ERROR] Code: {error_code}") print(f"[ERROR] Message: {error_message}") - print(f"[ERROR] Response: {e.response}\n") + print(f"[ERROR] Response: {e.response}") + if "invalid beta" in error_message.lower(): + print(f"[ERROR] Beta headers sent: {native_request.get('anthropic_beta', [])}") + print(f"[ERROR] Original anthropic-beta header: {anthropic_beta}") + print() # Map Bedrock error to appropriate exception raise map_bedrock_error(error_code, error_message) @@ -1389,6 +1393,8 @@ def _stream_worker_native( error_code = e.response["Error"]["Code"] error_message = e.response["Error"]["Message"] print(f"[ERROR] InvokeModelWithResponseStream ClientError: {error_code}: {error_message}") + if "invalid beta" in error_message.lower(): + print(f"[ERROR] Beta headers sent: {native_request.get('anthropic_beta', [])}") event_queue.put(("error", (error_code, error_message))) except Exception as e: