在工作流代码中从 defer（） 调用工作流活动是否安全？

Question

func MyWorkflow(ctx Context) (retErr error) { 
  log := workflow.GetLogger()
  log.Info("starting my workflow")
  defer func() {
    if retErr != nil {
      DoActivityCleanupError(ctx, ..)
    } else {
      DoActivityCleanupNoError(ctx, ...)
    }
  }
  err := DoActivityA(ctx, ...)
  if err != nil {
    return err
  }
  ...
  err := DoActivityB(ctx, ...)
  if err != nil {
    return err
  }
}
  

基本上，当工作流退出时（尤其是在我们不想在所有错误返回中重复调用ActivityCleanupError的错误情况下），我们都要执行catchall活动ActivityCleanupNoError和ActivityCLanupError。

这是否适用于分布式决策？例如，如果工作流决策的所有权从一个工作人员转移到另一个工作人员，是否会触发对原始工作人员的延迟？

额外的问题:日志记录器在每次工作流运行时只强制记录一次吗？即使决策从一个工人转移到另一个工人身上？您希望看到日志行出现在两个工人的日志中吗？还是幕后有魔法阻止这种事情发生？

Answer 1

是的。

但是要理解为什么它是安全的是相当复杂的。这是如何得到结论的:

>

在无粘性模式（无粘性缓存）下，Cadence SDK将始终执行工作流代码来做出（收集）工作流决策，并释放所有goroutines/堆栈。释放它们时，将执行延迟，这意味着清理活动代码路径将运行——然而，这些决策将被忽略。因此，它不会影响实际的正确性。

在粘性模式下，如果工作流未关闭，Cadence SDK将在某处阻塞；如果工作流实际上正在关闭，那么将执行延迟并收集决策。

当粘性缓存（goroutines/堆栈）被驱逐时，会发生什么与1.完全相同，所以它也是安全的。

记录器是否仅在每次工作流运行时强制记录一次？即使决策从一个工人转移到另一个工人身上？您希望看到日志行出现在两个工人的日志中吗？还是幕后有魔法阻止这种事情发生？

每个日志行将仅出现在实际执行代码作为决策的工作线程中 - 换句话说，在非重放模式下。这是唯一的神奇:)