streaming_response2.py

# Check for blocked message
if "input has been blocked by Veradigm's content filter" in response:
    if os.environ.get("VERA_DEBUG", "False") == "True":
        print("🚀 Full event payload:", full_event_payload)

    for event in full_event_payload:
        if "metadata" in event and "trace" in event["metadata"]:
            trace = event["metadata"]["trace"]
            guardrail = trace.get("guardrail", {})
            input_assessment = guardrail.get("inputAssessment", {})

            if guardrailIdentifier in input_assessment:
                assessment = input_assessment[guardrailIdentifier]
                filters = assessment.get("contentPolicy", {}).get("filters", [])