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

review completion signal

Browse Source
This commit is contained in:
Ian Gulliver
2026-10-16 10:46:42 -07:00
parent 91d95d0581
commit a800ac4f56
2 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/agents/lead.go
+9 -1
View File
@@ -316,7 +316,7 @@ func (m *Manager) warnLeadContext(ctx context.Context, l *live) error {
func (m *Manager) Observe(ev api.Event) {
switch ev.Kind {
case "inbox.created", "inbox.updated", "task.created", "task.merge_started", "task.merged", "task.discarded", "turn.ended", "task.workflow_stage", "task.workflow_finished":
case "inbox.created", "inbox.updated", "task.created", "task.merge_started", "task.merged", "task.discarded", "turn.ended", "task.workflow_stage", "task.workflow_finished", "review.finished":
case "user.message":
if ev.TaskId == nil || !humanActor(ev.Actor) {
return
@@ -485,6 +485,14 @@ func (m *Manager) signalText(ctx context.Context, ev api.Event) (string, error)
case "task.workflow_finished":
return fmt.Sprintf("%s finished workflow %q:\n%s", m.taskLabel(ctx, deref(ev.TaskId)), ev.Payload["workflow"], clip(fmt.Sprint(ev.Payload["output"]), 1500)), nil
case "review.finished":
r := api.Review{}
err := remarshal(ev.Payload, &r)
if err != nil {
return "", err
}
return fmt.Sprintf("%s %s", m.taskLabel(ctx, r.TaskId), reviewLine(r)), nil
case "user.message":
return fmt.Sprintf("%s sent %s a message; its agent is working on it.", ev.Actor, m.taskLabel(ctx, deref(ev.TaskId))), nil