fix(antigravity): 增加流式读取错误日志的账户信息
This commit is contained in:
@@ -438,6 +438,7 @@ func (s *AntigravityGatewayService) Forward(ctx context.Context, c *gin.Context,
|
|||||||
if claudeReq.Stream {
|
if claudeReq.Stream {
|
||||||
streamRes, err := s.handleClaudeStreamingResponse(c, resp, startTime, originalModel)
|
streamRes, err := s.handleClaudeStreamingResponse(c, resp, startTime, originalModel)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
log.Printf("%s status=stream_error error=%v", prefix, err)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
usage = streamRes.usage
|
usage = streamRes.usage
|
||||||
@@ -602,6 +603,7 @@ func (s *AntigravityGatewayService) ForwardGemini(ctx context.Context, c *gin.Co
|
|||||||
if stream || upstreamAction == "streamGenerateContent" {
|
if stream || upstreamAction == "streamGenerateContent" {
|
||||||
streamRes, err := s.handleGeminiStreamingResponse(c, resp, startTime)
|
streamRes, err := s.handleGeminiStreamingResponse(c, resp, startTime)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
log.Printf("%s status=stream_error error=%v", prefix, err)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
usage = streamRes.usage
|
usage = streamRes.usage
|
||||||
|
|||||||
Reference in New Issue
Block a user