diff --git a/temporal-sdk/src/main/java/io/temporal/internal/replay/ReplayWorkflowRunTaskHandler.java b/temporal-sdk/src/main/java/io/temporal/internal/replay/ReplayWorkflowRunTaskHandler.java index 190a6e647..0fa1485c0 100644 --- a/temporal-sdk/src/main/java/io/temporal/internal/replay/ReplayWorkflowRunTaskHandler.java +++ b/temporal-sdk/src/main/java/io/temporal/internal/replay/ReplayWorkflowRunTaskHandler.java @@ -218,7 +218,7 @@ public QueryResult handleDirectQueryWorkflowTask( } @Override - public void resetStartedEvenId(Long eventId) { + public void resetStartedEventId(Long eventId) { workflowStateMachines.resetStartedEventId(eventId); } diff --git a/temporal-sdk/src/main/java/io/temporal/internal/replay/ReplayWorkflowTaskHandler.java b/temporal-sdk/src/main/java/io/temporal/internal/replay/ReplayWorkflowTaskHandler.java index 5cc86051b..7e381199f 100644 --- a/temporal-sdk/src/main/java/io/temporal/internal/replay/ReplayWorkflowTaskHandler.java +++ b/temporal-sdk/src/main/java/io/temporal/internal/replay/ReplayWorkflowTaskHandler.java @@ -139,7 +139,7 @@ private Result handleWorkflowTaskWithQuery( workflowTask.getWorkflowType().getName(), workflowTask, wftResult, - workflowRunTaskHandler::resetStartedEvenId); + workflowRunTaskHandler::resetStartedEventId); } if (useCache) { diff --git a/temporal-sdk/src/main/java/io/temporal/internal/replay/WorkflowRunTaskHandler.java b/temporal-sdk/src/main/java/io/temporal/internal/replay/WorkflowRunTaskHandler.java index e0bac382c..f27eaafb0 100644 --- a/temporal-sdk/src/main/java/io/temporal/internal/replay/WorkflowRunTaskHandler.java +++ b/temporal-sdk/src/main/java/io/temporal/internal/replay/WorkflowRunTaskHandler.java @@ -61,7 +61,7 @@ QueryResult handleDirectQueryWorkflowTask( * * @param eventId the event ID to reset the cached state to. */ - void resetStartedEvenId(Long eventId); + void resetStartedEventId(Long eventId); void close(); } diff --git a/temporal-sdk/src/test/java/io/temporal/internal/sync/DeterministicRunnerTest.java b/temporal-sdk/src/test/java/io/temporal/internal/sync/DeterministicRunnerTest.java index 1966128b8..9358b02fa 100644 --- a/temporal-sdk/src/test/java/io/temporal/internal/sync/DeterministicRunnerTest.java +++ b/temporal-sdk/src/test/java/io/temporal/internal/sync/DeterministicRunnerTest.java @@ -809,7 +809,7 @@ public QueryResult handleDirectQueryWorkflowTask( } @Override - public void resetStartedEvenId(Long event) {} + public void resetStartedEventId(Long event) {} @Override public void close() {