def block_response_to_streaming_chunk()

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

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

def block_response_to_streaming_chunk(response: dict) -> dict:
    for choice in response["choices"]:
        choice["delta"] = choice["message"]
        del choice["message"]
        _add_indices(choice["delta"])
    return response