fix(coordinator): map engine-split sentinels to vocabulary

This commit is contained in:
WeiCHEN
2026-09-22 22:14:22 +08:00
parent 04d1b174e9
commit 0ad4ee319c
3 changed files with 8 additions and 8 deletions
+2 -2
View File
@@ -7,8 +7,8 @@ import (
"chat-agent-system/internal/agent"
"chat-agent-system/internal/app/stageflow"
"chat-agent-system/internal/contracts/vocabulary"
"chat-agent-system/internal/ctxmgr"
"chat-agent-system/internal/docgov"
"chat-agent-system/internal/intent"
"chat-agent-system/internal/kb"
"chat-agent-system/internal/projectinstance"
@@ -33,7 +33,7 @@ type PendingAction struct {
WorkDir string
Reason string
Comment string
Rollback docgov.DocumentState
Rollback vocabulary.DocumentState
TaskKey string
}
+3 -3
View File
@@ -1,12 +1,12 @@
package coordinator
import (
"chat-agent-system/internal/contracts/vocabulary"
"context"
"fmt"
"strings"
"time"
"chat-agent-system/internal/docgov"
"chat-agent-system/internal/intent"
)
@@ -323,9 +323,9 @@ func (e *CoordinatorEngine) handleDocGovProposalDecide(ctx context.Context, cand
}
userCtx.applyPending(nil)
rollback := docgov.StateDrafting
rollback := vocabulary.StateDrafting
if userCtx.InteractiveCard != nil && strings.Contains(userCtx.InteractiveCard.ImpactRisk, "reviewing") {
rollback = docgov.StateDrafting
rollback = vocabulary.StateDrafting
}
return &CoordinationResult{
+3 -3
View File
@@ -8,7 +8,7 @@ import (
"strings"
"chat-agent-system/internal/app/stageflow"
"chat-agent-system/internal/docgov"
"chat-agent-system/internal/contracts/vocabulary"
"chat-agent-system/internal/intent"
"chat-agent-system/internal/stream"
"chat-agent-system/internal/workflowscope"
@@ -100,7 +100,7 @@ func (e *CoordinatorEngine) handleTriggerTask(ctx context.Context, cand *intent.
UserID: userID,
})
if err != nil {
if errors.Is(err, docgov.ErrDocumentBusy) {
if errors.Is(err, vocabulary.ErrDocumentBusy) {
msg := "该文档正在由项目助手生成或他人编辑中,请稍后再发起更新。您可以先继续对话或处理其他文档。"
if taskRes != nil && taskRes.ErrorReason != "" {
msg = taskRes.ErrorReason + "。您可以先继续对话或处理其他文档。"
@@ -114,7 +114,7 @@ func (e *CoordinatorEngine) handleTriggerTask(ctx context.Context, cand *intent.
UpdatedContext: userCtx,
}, nil
}
if errors.Is(err, docgov.ErrDocumentLocked) {
if errors.Is(err, vocabulary.ErrDocumentLocked) {
return &CoordinationResult{
Status: StatusRejected,
Intent: cand.Intent,