diff --git a/.todo b/.todo deleted file mode 100644 index 0b9aae8..0000000 --- a/.todo +++ /dev/null @@ -1,11 +0,0 @@ -{ - "tasks": [ - { - "id": "1778047497735wxayc", - "title": "Review blocked/reverted work in update.sql", - "category": "Blocked", - "dueDate": null, - "completed": false - } - ] -} \ No newline at end of file diff --git a/consts/public/table_name.go b/consts/public/table_name.go index 8a01b23..f3ebed8 100644 --- a/consts/public/table_name.go +++ b/consts/public/table_name.go @@ -5,7 +5,6 @@ const ( ) const ( - TableNameModel = "asynch_models" // 模型表 TableNameComposeTask = "prompts_compose_task" // 拼接提示词任务记录表 TableNameComposeSession = "prompts_compose_session" // 拼接提示词会话记录表 TableNameProviderProtocol = "prompts_provider_protocol" diff --git a/service/session/prompt_session_service.go b/service/session/prompt_session_service.go index b93216e..8c3de77 100644 --- a/service/session/prompt_session_service.go +++ b/service/session/prompt_session_service.go @@ -9,6 +9,7 @@ import ( "gitea.redpowerfuture.com/red-future/common/beans" "gitea.redpowerfuture.com/red-future/common/utils" "github.com/gogf/gf/v2/frame/g" + "github.com/gogf/gf/v2/os/grpool" "github.com/gogf/gf/v2/util/gconv" "prompts-core/common/util" @@ -126,7 +127,13 @@ func GetHistoryMessages(ctx context.Context, req *dto.GetHistoryMessagesReq) (*d // 3) 转换 + 异步回种 rounds := sessionsToHistoryRounds(sessions) - go asyncCacheToRedis(context.WithoutCancel(ctx), user.TenantId, req.SessionId, req.NodeId, rounds) + + err = grpool.AddWithRecover(ctx, func(ctx context.Context) { + asyncCacheToRedis(ctx, user.TenantId, req.SessionId, req.NodeId, rounds) + }, nil) + if err != nil { + return nil, err + } return &dto.GetHistoryMessagesRes{Messages: flattenRounds(rounds)}, nil }