工作流与活动

// 在工作流中执行活动
func MyWorkflow(ctx workflow.Context) error {
    // 设置活动选项
    ao := workflow.ActivityOptions{
        StartToCloseTimeout: 10 * time.Second,
    }
    ctx = workflow.WithActivityOptions(ctx, ao)
    
    // 执行活动
    var result string
    err := workflow.ExecuteActivity(ctx, MyActivity, "param").Get(ctx, &result)
    if err != nil {
        return err
    }
    
    return nil
}