可能的错误：
当子 B 失败时，GenericWorkflowClientImpl 中的 handleStartChildWorkflowExecutionFailed 方法根据工作流 id 作为键从 scheduleExternalWorkflows 映射中删除了“OpenRequestInfo”。由于 5 个子工作流具有相同的工作流 ID。因此，一旦子 B 初始化失败，地图就会变为空。因此，父工作流无法完成，因为 4 个子工作流请求永远无法在 handle* 方法中正确关闭。
第 335 行显示 handleStartChildWorkflowExecutionFailed 删除失败的条目。
【问题讨论】：
标签： amazon-web-services workflow aws-sdk amazon-swf
@Override
protected ExternalTaskCancellationHandler doExecute(final ExternalTaskCompletionHandle handle) throws Throwable {
context.setCompletionHandle(handle);
String workflowId = attributes.getWorkflowId();
if (scheduledExternalWorkflows.containsKey(workflowId)) {
WorkflowExecution workflowExecution = new WorkflowExecution();
workflowExecution.setWorkflowId(workflowId);
WorkflowType workflowType = attributes.getWorkflowType();
long fakeEventId = -1;
handle.fail(new StartChildWorkflowFailedException(fakeEventId, workflowExecution, workflowType, StartChildWorkflowExecutionFailedCause.WORKFLOW_ALREADY_RUNNING.toString()) );
return new ChildWorkflowCancellationHandler(workflowId, handle);
}
decisions.startChildWorkflowExecution(attributes);
scheduledExternalWorkflows.put(workflowId, context);
return new ChildWorkflowCancellationHandler(workflowId, handle);
}
}
}
更新了这个类的第 162 行：
【讨论】：
Update2：问题仍未解决 :(.
更新：可能是提交 0a183e02b29b06e9324b740af40daff9193c9290 修复了该错误。请验证。
这看起来像是DecisionsHelper 中的一个错误。它假定 DecisionId 永远不会被重用，因为它永远不会从 decisions 映射中删除。 DecisionId 永远不会重用于活动和 lambda，但正如您发现的那样，子工作流并不总是如此:(。解决方法是不重用子工作流 id。
在您的情况下，我看不到尝试安排与父工作流具有相同 ID 的子工作流的原因，因为它具有有关子工作流状态的完整信息，并且可以轻松避免它。顺便说一句，您是否考虑过在 CronWithRety 示例中将 CronInvocationSchedule 与 AsyncScheduledExecutor 一起使用？
但是，当父工作流的多个实例可以创建具有相同 id 的子工作流时，这个错误是很糟糕的。
【讨论】：