如何在zeebe中重新启动作业



我有一个方法,作为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)
}

您需要在流程模型的任务属性中指定重试次数。

最新更新