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