【发布时间】:2021-07-07 13:45:56
【问题描述】:
我有方法,作为 zeebe 工作流工作的一部分。当它失败时,我想重新启动所有工作。我发现,它可以用 NewFailJobCommand 来完成,但似乎第一次尝试就失败了。如果作业失败,我如何重新开始作业?
err := w.workflowStore.InitScanEventsTTL(ctx, scanID, job.Msg.Tenant)
if err != nil {
return w.client.NewFailJobCommand().JobKey(job.Key).Retries(job.Retries -
1).ErrorMessage(reason).Send(ctx)
}
【问题讨论】:
-
当您说
it seems that the job fails on the first try时,我不清楚您的意思。你的意思是InitScanEventsTTL调用总是为err返回一个非零值吗?或者NewFailJobCommand不能发送成功?还是您的代码中抛出了错误?或者失败命令会导致流程实例中的事件?请为您的问题提供一些其他详细信息