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
index fc0d8c9c7..7d26c4833 100644
--- 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,