def annotate_stream()

in aidial_interceptors_sdk/utils/streaming.py [0:0]

• 2 lines of code
• 1 McCabe index (conditional complexity)

def annotate_stream(
    annotation: Annotation, stream: AsyncIterator[dict | DialException]