From 15d673fbf0f99c8efc41eabd7f7637987c1ccdf8 Mon Sep 17 00:00:00 2001 From: David Justo Date: Mon, 8 Jul 2024 15:53:06 -0700 Subject: [PATCH] clear executionID --- src/DurableTask.Core/Entities/ClientEntityHelpers.cs | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/DurableTask.Core/Entities/ClientEntityHelpers.cs b/src/DurableTask.Core/Entities/ClientEntityHelpers.cs index 94bc0512a..fc4457d10 100644 --- a/src/DurableTask.Core/Entities/ClientEntityHelpers.cs +++ b/src/DurableTask.Core/Entities/ClientEntityHelpers.cs @@ -67,6 +67,9 @@ public static EntityMessageEvent EmitUnlockForOrphanedLock(OrchestrationInstance Id = "fix-orphaned-lock", // we don't know the original id but it does not matter }; + // Since entities are always calling continue-as-new (which changes the executionID), we need to clear it. + // By clearing it, we ensure the event is received by the current entity execution. + targetInstance.ExecutionId = null; return new EntityMessageEvent(EntityMessageEventNames.ReleaseMessageEventName, message, targetInstance); }