def on_upstream_chunk()

in aidial_interceptors_sdk/chat_completion/adapter.py [0:0]

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

        def on_upstream_chunk(chunk: ChatCompletionChunk) -> dict:
            d = chunk.to_dict()
            if _log.isEnabledFor(logging.DEBUG):
                _log.debug(f"upstream chunk[{context}]: {json.dumps(d)}")
            return d