Go 实现 /api/v1/analysis 契约、Demo/Live Worker、DeerFlow SSE;含设计文档与冒烟脚本。 Co-authored-by: Cursor <cursoragent@cursor.com>
22 lines
708 B
Go
22 lines
708 B
Go
package domain
|
|
|
|
// 会商作业状态(与 Java JobStatus / 前端约定一致,勿自创别名)。
|
|
const (
|
|
StatusQueued = "queued"
|
|
StatusRunning = "running"
|
|
StatusAwaitingInput = "awaiting_input"
|
|
StatusDone = "done"
|
|
StatusError = "error"
|
|
StatusCancelled = "cancelled"
|
|
)
|
|
|
|
// IsActive 是否仍可能被 worker 推进(含等人中)。
|
|
func IsActive(status string) bool {
|
|
return status == StatusQueued || status == StatusRunning || status == StatusAwaitingInput
|
|
}
|
|
|
|
// IsTerminal 是否已结束,不应再 resume / inject / 改计划。
|
|
func IsTerminal(status string) bool {
|
|
return status == StatusDone || status == StatusError || status == StatusCancelled
|
|
}
|