i/Aether
1
0
Fork 0
mirror of https://github.com/fawney19/Aether.git synced 2026-09-02 17:30:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(task): 修复 SyncTaskExecutionService 调用 dispatch 缺少 user_id 参数及返回值解包数量不匹配

Browse Source
This commit is contained in:
fawney19
2026-03-07 17:32:17 +08:00
parent a00e137ffc
commit 06b483f79d
1 changed files with 25 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
src/services/task/execute/sync_execute.py
View File

@@ -228,25 +228,32 @@ class SyncTaskExecutionService:
candidate_record_id candidate_record_id
) )
response, _provider_name, attempt_id, _provider_id, _endpoint_id, _key_id = ( (
await request_dispatcher.dispatch( response,
candidate=candidate, _provider_name,
candidate_index=candidate_index, attempt_id,
retry_index=retry_index, _provider_id,
candidate_record_id=candidate_record_id, _endpoint_id,
user_api_key=user_api_key, _key_id,
request_func=request_func, _first_byte_time_ms,
request_id=request_id, ) = await request_dispatcher.dispatch(
api_format=api_format_norm, candidate=candidate,
model_name=model_name, candidate_index=candidate_index,
affinity_key=affinity_key, retry_index=retry_index,
global_model_id=global_model_id, candidate_record_id=candidate_record_id,
attempt_counter=attempt_counter, user_api_key=user_api_key,
max_attempts=max_attempts_local, user_id=user_id,
is_stream=is_stream, request_func=request_func,
) request_id=request_id,
api_format=api_format_norm,
model_name=model_name,
affinity_key=affinity_key,
global_model_id=global_model_id,
attempt_counter=attempt_counter,
max_attempts=max_attempts_local,
is_stream=is_stream,
) )
_ = (attempt_id, _provider_name, _provider_id, _endpoint_id, _key_id) _ = (attempt_id, _provider_name, _provider_id, _endpoint_id, _key_id, _first_byte_time_ms)
# Account Pool: on success, update sticky binding + LRU. # Account Pool: on success, update sticky binding + LRU.
await self._pool_ops.pool_on_success(candidate, request_body) await self._pool_ops.pool_on_success(candidate, request_body)