ai/byre
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 6 Wiki Activity

missing suggest_discard

Browse Source
This commit is contained in:
Ian Gulliver
2026-10-19 19:56:59 -07:00
parent 613640fab4
commit 36f4955a09
3 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/agents/lead.go
+3
View File
@@ -326,6 +326,9 @@ func (m *Manager) Observe(events []api.Event) {
if ev.Kind == "task.state" && ev.Payload["to"] == string(api.TaskStateIdle) && ev.TaskId != nil {
go m.promptReady(*ev.TaskId, ev.Payload["from"])
}
if ev.Kind == "task.workflow_finished" && ev.TaskId != nil {
go m.promptReady(*ev.TaskId, nil)
}
switch ev.Kind {
case "inbox.created", "inbox.updated", "task.created", "task.merge_queued", "task.merge_after_review", "task.merge_after_review_cancelled", "task.merge_after_review_dropped", "task.merge_started", "task.merged", "task.discarded", "turn.ended", "task.workflow_stage", "task.workflow_finished", "review.started", "review.finished", "task.state", "task.ready", "task.discard_suggested":
case "user.message":
internal/agents/ready.go
+7 -1
View File
@@ -117,9 +117,15 @@ func (m *Manager) tryPromptReady(ctx context.Context, taskID string, fromReview
if err != nil {
return err
}
if task.Status != api.TaskStatusActive || task.State != api.TaskStateIdle || task.WorkflowStage != nil || task.MergeAfterReview {
if task.Status != api.TaskStatusActive || task.State != api.TaskStateIdle || task.MergeAfterReview {
return nil
}
if task.WorkflowStage != nil {
finished, err := m.store.WorkflowFinished(ctx, *task.WorkflowRun)
if err != nil || !finished {
return err
}
}
sess, err = m.store.GetSession(ctx, sess.Id)
if err != nil || sess.State == api.AgentSessionStateRunning || m.interrupted(sess.Id) {
return err