Function NewAgentTaskRuntime

agent/task_runtime.go:139–153

()

}

func NewAgentTaskRuntime() *AgentTaskRuntime {
	return &AgentTaskRuntime{
		records:                 map[string]*AgentTaskRecord{},
		notifications:           map[string][]TaskNotification{},
		waiters:                 map[string][]chan struct{}{},
		workers:                 map[string]context.CancelFunc{},
		workerSpecs:             map[string]workerSpec{},
		scopes:                  map[string]struct{}{"main": {}},
		childCounts:             map[string]int{},
		taskParentScopes:        map[string]string{},
		expiredTaskParentScopes: map[string]string{},
		recordCleanupCancels:    map[string]context.CancelFunc{},
		idleTTLCancels:          map[string]context.CancelFunc{},
	}
}

func (rt *AgentTaskRuntime) ExportSnapshot() []map[string]any {
	rt.mu.Lock()