我有一个方法,作为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)
}
您需要在流程模型的任务属性中指定重试次数。