diff --git a/src/main/java/com/uber/cadence/internal/replay/ReplayDecisionTaskHandler.java b/src/main/java/com/uber/cadence/internal/replay/ReplayDecisionTaskHandler.java index 2ffaaab41..0afa4848f 100644 --- a/src/main/java/com/uber/cadence/internal/replay/ReplayDecisionTaskHandler.java +++ b/src/main/java/com/uber/cadence/internal/replay/ReplayDecisionTaskHandler.java @@ -274,6 +274,9 @@ private Decider createDecider(PollForDecisionTaskResponse decisionTask) throws E .setExecution(decisionTask.getWorkflowExecution()); GetWorkflowExecutionHistoryResponse getHistoryResponse = service.GetWorkflowExecutionHistory(getHistoryRequest); + if (getHistoryResponse.getHistory().getEventsSize() == 0) { + throw new RuntimeException("Failed to get workflow execution history for replay"); + } decisionTask.setHistory(getHistoryResponse.getHistory()); decisionTask.setNextPageToken(getHistoryResponse.getNextPageToken()); }