74
ctx context.Context,
75
executable queues.Executable,
77
>
task := executable.GetTask()
78
>
taskType := queues.GetVisibilityTaskTypeTagValue(task)
79
>
namespaceTag, replicationState := getNamespaceTagAndReplicationStateByID(
80
>
t.shardContext.GetNamespaceRegistry(),
81
>
task.GetNamespaceID(),
82
>
executable.GetWorkflowID(),
83
>
)
84
>
metricsTags := []metrics.Tag{
85
>
namespaceTag,
86
>
metrics.TaskTypeTag(taskType),
87
>
metrics.OperationTag(taskType), // for backward compatibility
88
>
}
89
>
90
>
if replicationState == enumspb.REPLICATION_STATE_HANDOVER {
91
// TODO: exclude task types here if we believe it's safe & necessary to execute
92
// them during namespace handover.