137
return nsError
138
} else if !apply {
140
>
tag.WorkflowNamespaceID(e.NamespaceID),
141
>
tag.WorkflowID(e.WorkflowID),
142
>
tag.WorkflowRunID(e.RunID),
143
>
tag.TaskID(e.TaskID()),
144
>
)
145
>
metrics.ReplicationTasksSkipped.With(e.MetricsHandler).Record(
146
>
1,
147
>
metrics.OperationTag(metrics.SyncActivityTaskScope),
148
>
metrics.NamespaceTag(namespaceName),
149
>
)
150
>
return nil
151
>
}
152
ctx, cancel := newTaskContext(namespaceName, e.Config.ReplicationTaskApplyTimeout(), callerInfo)
153
defer cancel()