Use latest worker identity for pending activity (#2350)

temporalio · Jan 7, 2022 · cf6c03e · cf6c03e
1 parent ffc6071
commit cf6c03e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/service/history/historyEngine.go b/service/history/historyEngine.go
@@ -1251,7 +1251,7 @@ func (e *historyEngineImpl) DescribeWorkflowExecution(
 				if ai.RetryLastFailure != nil {
 					p.LastFailure = ai.RetryLastFailure
 				}
-				if ai.RetryLastWorkerIdentity != "" {
+				if p.LastWorkerIdentity == "" && ai.RetryLastWorkerIdentity != "" {
 					p.LastWorkerIdentity = ai.RetryLastWorkerIdentity
 				}
 			} else {