110
currentCluster := e.ClusterMetadata.GetCurrentClusterName()
111
if namespaceEntry.ActiveClusterName(namespace.RoutingKey{ID: e.BusinessID}) == currentCluster {
112
>
e.Logger.Warn("Skipping delete execution replication task on active cluster",
executable_delete_execution_task.go
113
>
tag.WorkflowNamespaceID(e.NamespaceID),
114
>
tag.WorkflowID(e.BusinessID),
115
>
tag.WorkflowRunID(e.RunID),
116
>
tag.TaskID(e.TaskID()),
117
>
tag.ClusterName(currentCluster),
118
>
)
119
>
metrics.ReplicationTasksSkipped.With(e.MetricsHandler).Record(
120
>
1,
121
>
metrics.OperationTag(metrics.DeleteExecutionReplicationTaskScope),
122
>
metrics.NamespaceTag(namespaceName),
123
>
)
124
>
return nil
125
>
}
126
127
ctx, cancel := newTaskContext(namespaceName, e.Config.ReplicationTaskApplyTimeout(), callerInfo)