Skip to content

Commit 2ff25d9

Browse files
missing ctx
1 parent dffc954 commit 2ff25d9

File tree

2 files changed

+4
-5
lines changed

2 files changed

+4
-5
lines changed

apisix/plugins/ai-proxy-multi.lua

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -186,7 +186,6 @@ local function get_load_balanced_provider(ctx, conf, ups_tab, request_table)
186186
end
187187

188188
ai_proxy.get_model_name = function (...)
189-
190189
end
191190

192191

@@ -201,15 +200,15 @@ ai_proxy.proxy_request_to_llm = function (conf, request_table, ctx)
201200
end
202201

203202
::retry::
204-
local provider_name, provider_conf = get_load_balanced_provider(ctx, conf, ups_tab, request_table)
203+
local provider, provider_conf = get_load_balanced_provider(ctx, conf, ups_tab, request_table)
205204
local extra_opts = {
206205
endpoint = core.table.try_read_attr(provider_conf, "override", "endpoint"),
207206
query_params = provider_conf.auth.query or {},
208207
headers = (provider_conf.auth.header or {}),
209208
model_options = provider_conf.options,
210209
}
211210

212-
local ai_driver = require("apisix.plugins.ai-proxy.drivers." .. provider_name)
211+
local ai_driver = require("apisix.plugins.ai-proxy.drivers." .. provider)
213212
local res, err, httpc = ai_driver:request(conf, request_table, extra_opts)
214213
if not res then
215214
if (ctx.balancer_try_count or 0) < 1 then

apisix/plugins/ai-proxy.lua

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ function _M.get_model_name(conf)
5959
end
6060

6161

62-
function _M.proxy_request_to_llm(conf, request_table)
62+
function _M.proxy_request_to_llm(conf, request_table, ctx)
6363
local ai_driver = require("apisix.plugins.ai-proxy.drivers." .. conf.model.provider)
6464
local extra_opts = {
6565
endpoint = core.table.try_read_attr(conf, "override", "endpoint"),
@@ -96,7 +96,7 @@ function _M.access(conf, ctx)
9696
request_table.stream = true
9797
end
9898

99-
local res, err, httpc = _M.proxy_request_to_llm(conf, request_table)
99+
local res, err, httpc = _M.proxy_request_to_llm(conf, request_table, ctx)
100100
if not res then
101101
core.log.error("failed to send request to LLM service: ", err)
102102
return internal_server_error

0 commit comments

Comments
 (0)