Method executeAsync

pkg/middleware/subagent.go:330–361

executeAsync 异步执行子代理

(ctx context.Context, subagentType, description string, parentContext map[string]any, timeout time.Duration)

// executeAsync 异步执行子代理
func (t *TaskTool) executeAsync(ctx context.Context, subagentType, description string, parentContext map[string]any, timeout time.Duration) (any, error) {
	// 构建子代理配置
	config := &builtin.SubagentConfig{
		Type:          subagentType,
		Prompt:        description,
		Timeout:       timeout,
		ParentContext: parentContext,
		Metadata: map[string]string{
			"subagent_type": subagentType,
			"description":   description,
		},
	}

	// 启动子代理
	instance, err := t.middleware.manager.StartSubagent(ctx, config)
	if err != nil {
		return map[string]any{
			"ok":    false,
			"error": fmt.Sprintf("failed to start subagent: %v", err),
		}, nil
	}

	saLog.Info(ctx, "started async subagent", map[string]any{"subagent": subagentType, "task_id": instance.ID})

	return map[string]any{
		"ok":            true,
		"task_id":       instance.ID,
		"subagent_type": subagentType,
		"status":        instance.Status,
		"message":       "SubAgent started in background. Use query_subagent to check status and get results.",
	}, nil
}

func (t *TaskTool) Prompt() string {
	// 获取可用的子代理列表