yumoqing/bricks
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2026-06-10 15:18:00 +08:00
parent 1031c77dda
commit 78a0e3a791
1 changed files with 4 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
bricks/llm.js
View File

@ -259,6 +259,7 @@ bricks.LlmModel = class extends bricks.JsWidget {
} }
async query_task_status(mout, taskid){ async query_task_status(mout, taskid){
var pt = this.opts.period_time || 30 * 1000; var pt = this.opts.period_time || 30 * 1000;
while (1){
var hj = new bricks.HttpJson() var hj = new bricks.HttpJson()
var d = { var d = {
taskid: taskid taskid: taskid
@ -276,7 +277,9 @@ bricks.LlmModel = class extends bricks.JsWidget {
if (data.status == 'FAILED' || data.status == 'SUCCEEDED'){ if (data.status == 'FAILED' || data.status == 'SUCCEEDED'){
return; return;
} }
schedule_once(this.query_task_status.bind(this), pt) await bricks.sleep(pt);
}
//schedule_once(this.query_task_status.bind(this), pt)
} }
chunk_response(mout, l){ chunk_response(mout, l){
l = l.trim(); l = l.trim();
@ -286,11 +289,6 @@ bricks.LlmModel = class extends bricks.JsWidget {
console.log(l, 'is not a json data'); console.log(l, 'is not a json data');
return return
} }
if (this.opts.response_mode == 'async'){
if (d.taskid){
this.query_task_status(mout, d.taskid)
}
}
console.log('l=', l, 'd=', d); console.log('l=', l, 'd=', d);
mout.update_data(d); mout.update_data(d);
} }