Skip to content

Commit 2d5963a

Browse files
Remove workflow context lock from retry path (#808)
1 parent 61fd87b commit 2d5963a

File tree

1 file changed

+0
-7
lines changed

1 file changed

+0
-7
lines changed

internal/internal_task_handlers.go

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -874,13 +874,6 @@ func (w *workflowExecutionContextImpl) retryLocalActivity(lar *localActivityResu
874874
if backoff > 0 && backoff <= w.GetDecisionTimeout() {
875875
// we need a local retry
876876
time.AfterFunc(backoff, func() {
877-
w.Lock()
878-
defer w.Unlock(nil)
879-
880-
// after backoff, check if it is still relevant
881-
if w.IsDestroyed() {
882-
return
883-
}
884877
if _, ok := w.eventHandler.pendingLaTasks[lar.task.activityID]; !ok {
885878
return
886879
}

0 commit comments

Comments
 (0)