github/sub2api
4
0 Fork 0
mirror of https://github.com/Wei-Shaw/sub2api.git synced 2026-11-12 22:42:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #2855 from gaoren002/fix/concurrency-error-classification

Browse Source 
fix: classify concurrency acquire failures
This commit is contained in:
Wesley Liddick authored and GitHub committed 2026-05-29 10:33:40 +08:00
2 parents e6a3f1e12b 56e96fdd8c
commit 21cd382f39
6 files changed
+118 -6
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

backend/internal/handler/openai_gateway_handler.go
+3 -3
View File
@@ -1688,10 +1688,10 @@ func (h *OpenAIGatewayHandler) acquireImageGenerationSlot(c *gin.Context, stream
return nil, false
}
// handleConcurrencyError handles concurrency-related errors with proper 429 response
// handleConcurrencyError handles concurrency-related acquire errors.
func (h *OpenAIGatewayHandler) handleConcurrencyError(c *gin.Context, err error, slotType string, streamStarted bool) {
h.handleStreamingAwareError(c, http.StatusTooManyRequests, "rate_limit_error",
fmt.Sprintf("Concurrency limit exceeded for %s, please retry later", slotType), streamStarted)
status, errType, message := concurrencyErrorResponse(err, slotType)
h.handleStreamingAwareError(c, status, errType, message, streamStarted)
}
func (h *OpenAIGatewayHandler) handleFailoverExhausted(c *gin.Context, failoverErr *service.UpstreamFailoverError, streamStarted bool) {