Do not double execute close execution task if visibility archival is …

…disabled (#3072)
temporalio · Jul 8, 2022 · 56c5295 · 56c5295
1 parent 646f12d
commit 56c5295
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/service/history/transferQueueStandbyProcessor.go b/service/history/transferQueueStandbyProcessor.go
@@ -88,9 +88,13 @@ func newTransferQueueStandbyProcessor(
 		case enumsspb.TASK_TYPE_TRANSFER_RESET_WORKFLOW:
 			// no reset needed for standby
 			return false
-		case enumsspb.TASK_TYPE_TRANSFER_CLOSE_EXECUTION,
-			enumsspb.TASK_TYPE_TRANSFER_DELETE_EXECUTION:
+		case enumsspb.TASK_TYPE_TRANSFER_DELETE_EXECUTION:
 			return true
+		case enumsspb.TASK_TYPE_TRANSFER_CLOSE_EXECUTION:
+			if shard.GetArchivalMetadata().GetVisibilityConfig().ClusterConfiguredForArchival() {
+				return true
+			}
+			fallthrough
 		default:
 			return taskAllocator.verifyStandbyTask(clusterName, namespace.ID(task.GetNamespaceID()), task)
 		}