Uber Cadence工作流版本控制

Question

节奏工作流版本控制：

工作流执行具有以下代码：

        int version1 = Workflow.getVersion("change123", Workflow.DEFAULT_VERSION, 1);
        logger.info("version1: {}", version1);

工作流1： o/p的开始--版本1:1

工作流实施中的更改:

        int version1 = Workflow.getVersion("change1234", Workflow.DEFAULT_VERSION, 2);
        logger.info("version1: {}", version1);       

工作流2： o/p的开始--版本1:2

工作流实施中的更改:

       int version1 = Workflow.getVersion("change12345", Workflow.DEFAULT_VERSION, 3);
       logger.info("version1: {}", version1);        

工作流3： o/p的开始--版本1:3

工作流2的重放:o/p版本1: -1

工作流重播 1 ： o/p --version1： -1

我期待低于o / p

重播工作流程2： o/p--版本1:2

工作流重播 1 ： o/p -- 版本 1： 1

这意味着我们一次只能维护两个版本的工作流代码，

当前版本和所有旧版本的getVersion将给出工作流。默认_版本

如果我错了，请纠正我！

Answer 1

问题是您传入了不同的更改 ID

要为同一部分维护不同的版本，您必须继续使用相同的change eID，除非稍后不推荐使用change eID，但您想再次进行更改。

ChangID 是工作流中的标识符，用于区分更改的不同部分。例如，您的工作流程：

String resA = activities.executeA();

String resB = activities.executeB();

如果您想对executeA=进行更改

int versionA = Workflow.getVersion("changeToA", Workflow.DEFAULT_VERSION, 1);

if(versionA == 1){
  String resA = activities.executeAA();
}else{
  String resA = activities.executeA();
}


String resB = activities.executeB();

然后如果你想改变executeAA=

int versionA = Workflow.getVersion("changeToA", Workflow.DEFAULT_VERSION, 2);

if(versionA == 2){
  String resA = activities.executeAAA();
}else if versionA == 1{
  String resA = activities.executeAA();
}else{
  String resA = activities.executeA();
}


String resB = activities.executeB();

以便您可以维护多个版本。

然后，如果您想进行更改以执行B=

int versionA = Workflow.getVersion("changeToA", Workflow.DEFAULT_VERSION, 2);

if(versionA == 2){
  String resA = activities.executeAAA();
}else if versionA == 1{
  String resA = activities.executeAA();
}else{
  String resA = activities.executeA();
}

int versionB = Workflow.getVersion("changeToB", Workflow.DEFAULT_VERSION, 1);

if(versionB == 1){
  String resB = activities.executeBB();
}else{
  String resB = activities.executeB();
}

这里的关键是理解change eID，它确实有点棘手，但是一旦你得到它，它就很强大。

在代码中，由于您始终进行不同的更改 ID，因此已启动的工作流（工作流 1 和工作流 2）将始终获得DEFAULT_VERSION（-1）。

在内部，当处于执行模式（非重放）时，getVersion会在执行代码时将带有MaxVersion的Marker事件写入历史记录。

在重放模式下，如果Marker存在（ChangeID必须匹配，否则忽略标记），则返回Marker的版本，如果不存在（因为workflow 1在其执行模式下没有getVersion代码），则使用minVersion（在您的情况下是DEFAULT_VERSION）。（

查看更多文档：

为了golang

对于java