Method enqueueLocked

agent/task_runtime.go:729–757

(record *AgentTaskRecord, summary, result string)

}

func (rt *AgentTaskRuntime) enqueueLocked(record *AgentTaskRecord, summary, result string) {
	notification := TaskNotification{
		NotificationID: uuid.NewString()[:12],
		TaskID:         record.TaskID, ParentTaskID: record.ParentTaskID, ParentScopeID: record.ParentScopeID,
		Status: record.Status, Summary: summary, Result: result,
		Usage: map[string]int{"input_tokens": record.InputTokens, "output_tokens": record.OutputTokens},
	}
	rt.notifications[record.ParentScopeID] = append(rt.notifications[record.ParentScopeID], notification)
	if rt.taskEventSink != nil {
		eventType := "task_snapshot_updated"
		if _, terminal := terminalTaskStatuses[record.Status]; terminal {
			eventType = "task_summary_available"
		}
		rt.taskEventSink.EmitTaskEvent(TaskUIEvent{
			Type:       eventType,
			TaskID:     record.TaskID,
			Record:     record.ToMap(),
			Summary:    summary,
			ResultText: result,
		})
	}
	for _, waiter := range rt.waiters[record.TaskID] {
		select {
		case waiter <- struct{}{}:
		default:
		}
	}
	rt.waiters[record.TaskID] = nil
}

func (rt *AgentTaskRuntime) getTaskLocked(taskID, scopeID string, forceScopeCheck bool) *AgentTaskRecord {
	record := rt.records[taskID]