引入版本控制后，节奏工作流未执行活动

Question

我在节奏工作流中引入了节奏版本控制，之后工作流在版本控制引入时停止执行。我收到以下错误：

2020-10-29T07:23:49.587Z调试内部/内部事件处理程序。go:465执行活动{“域”：“域_1”，“任务列表”：“任务列表_1”、“工作人员ID”：“6@cdnc-5ddb9ccbb5-5dt5j@tasklist“，”WorkflowType“：”do_work_workflow“，”WorkflowID“：”CREATE“，”RunID“：“cab97b65-9892-48c5-b842-3f8b462d8602”，“ActivityID”：“4”，“ActivityType”：“do_Task_D”}2020-10-29T07:23:49.620Z DEBUG internal/internal_Task_handlers。go:1077缓存状态过时，新任务具有意外事件{“Domain”：“Domain_1”，“tasklist”：”tasklist_1“，“WorkerID“：”6@cdnc-5ddb9ccbb5-5dt5j@tasklist1“，”WorkflowID“：”CREATE“，”RunID“：

我的工作流代码将如下所示：

func doWorkflow(ctx workflow.Context, input string) error {
    err := doTaskA(input)
    if err != nil {
        return err
    }
    err = doTaskB(input)
    if err != nil {
        return err
    }
    versionTaskC := workflow.GetVersion(ctx, "ChangeID", workflow.DefaultVersion, 1)
    if versionTaskC == workflow.DefaultVersion {
        err = doTaskC(input)
        if err != nil {
            return err
        }
    } else {
        err = doTaskD(input)
        if err != nil {
            return err
        }
    }
    err = doTaskD2(input)
    if err != nil {
        return err
    }
    err = doTaskD3(input)
    if err != nil {
        return err
    }
    return nil
}

在ChangeID处，返回的版本为1，工作流尝试执行TaskD，但它没有执行它，它陷入了无限循环中，试图执行TaskD。

我收到的错误消息是

缓存状态已过时，新任务具有意外事件

和

错误请求错误{消息： 节奏更改版本不是有效的搜索属性}

你能帮我解决这个问题吗？

Answer 1

有两种可能：

< li >您正在运行版本低于0.11的Cadence服务器。 < Li >[很有可能]您的Cadence服务器从较低版本升级，但没有更改elasticSearch模式:

cadence admin cluster add-search-attr --search_attr_key CadenceChangeVersion --search_attr_type 1

您可能还需要添加以下内容：

cadence admin cluster add-search-attr --search_attr_key BinaryChecksums --search_attr_type 1

背景：

节奏变化版本在 https://github.com/uber/cadence/releases/tag/v0.11.0 中引入

这是为了帮助搜索工作流更改版本。

如果这不正确，请告诉我。