95
return err
96
} else if !apply {
98
>
tag.WorkflowNamespaceID(e.NamespaceID),
99
>
tag.WorkflowID(e.WorkflowID),
100
>
tag.WorkflowRunID(e.RunID),
101
>
tag.TaskID(e.TaskID()),
102
>
)
103
>
metrics.ReplicationTasksSkipped.With(e.MetricsHandler).Record(
104
>
1,
105
>
metrics.OperationTag(metrics.SyncWorkflowStateTaskScope),
106
>
metrics.NamespaceTag(namespaceName),
107
>
)
108
>
return nil
109
>
}
110
ctx, cancel := newTaskContext(namespaceName, e.Config.ReplicationTaskApplyTimeout(), callerInfo)
111
defer cancel()