我有一个有三个活动的工作流。场景。第一个活动在执行第二个活动时完成,达到重试限制后工作流失败。现在问题已经解决了。如何重新启动失败的工作流。
我读过这个问题,相关问题。
我想知道如何使用中的重置API来实现它。
cadence-依赖性:编译组:'com.uber.cadence',名称:'cadence-client',版本:'3.5.0‘
谢谢你的帮助。
发布于 2022-10-16 14:18:01
在WorkflowServiceTChannel类中,我找到了一个方法ResetWorkflowExecution。通过它,复位就可以实现了。代码显示为blow:
公共空testReset(String,String,){
ClientOptions.newBuilder().setHost("127.0.0.1").setPort(8080).setFeatureFlags(new FeatureFlags().setWorkflowExecutionAlreadyCompletedErrorEnabled(true)).build()),WorkflowClientOptions.newBuilder().setDomain("domain-test").build());WorkflowClient workflowClient = WorkflowClient.newInstance(新WorkflowServiceTChannel)
ResetWorkflowExecutionRequest请求=新的ResetWorkflowExecutionRequest();
WorkflowExecution workflowExecution =新WorkflowExecution();
WorkflowExecution.setWorkflowId(工作流);
workflowExecution.setRunId(runid);
request.setRequestId(UUID.randomUUID().toString());
Request.setDomain(“域测试”);
request.setDecisionFinishEventId(Long.valueOf(completeid));
request.setWorkflowExecution(workflowExecution);
尝试{
workflowClient.getService().ResetWorkflowExecution(request);
} catch (TException e) {
e.printStackTrace();
}
}
发布于 2022-10-11 07:10:02
https://stackoverflow.com/questions/74017038
复制相似问题