Method snapshot

agent/task_runtime.go:690–715

(taskIDs []string, scopeID string)

}

func (rt *AgentTaskRuntime) snapshot(taskIDs []string, scopeID string) map[string]any {
	rt.mu.Lock()
	defer rt.mu.Unlock()
	var tasks []map[string]any
	var pending []string
	var missing []string
	for _, id := range taskIDs {
		record := rt.getTaskLocked(id, scopeID, true)
		if record == nil {
			missing = append(missing, id)
			continue
		}
		tasks = append(tasks, serializeTaskPayload(record.ToMap()))
		if !isStableTask(record) {
			pending = append(pending, id)
		}
	}
	return map[string]any{
		"tasks":                 tasks,
		"timeout":               false,
		"pending_task_ids":      pending,
		"missing_task_ids":      missing,
		"expired_task_ids":      []string{},
		"inaccessible_task_ids": []string{},
	}
}

func isStableTask(record *AgentTaskRecord) bool {
	if record == nil {