Fix accidentally removed call to newAttempt for LAs

temporalio · Mar 25, 2024 · 0c2a4a1 · 0c2a4a1
1 parent b126f7e
commit 0c2a4a1
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/temporal-sdk/src/main/java/io/temporal/internal/worker/LocalActivityWorker.java b/temporal-sdk/src/main/java/io/temporal/internal/worker/LocalActivityWorker.java
@@ -423,6 +423,7 @@ public void handle(LocalActivityAttemptTask attemptTask) throws Exception {
           scheduleToStartFuture != null && !scheduleToStartFuture.cancel(false);
 
       LocalActivityExecutionContext executionContext = attemptTask.getExecutionContext();
+      executionContext.newAttempt();
       PollActivityTaskQueueResponseOrBuilder activityTask = attemptTask.getAttemptTask();
 
       // if an activity was already completed by any mean like scheduleToClose or scheduleToStart,