65
ctx context.Context,
66
executable queues.Executable,
68
>
task := executable.GetTask()
69
>
namespaceTag, replicationState := getNamespaceTagAndReplicationStateByID(
70
>
e.shardContext.GetNamespaceRegistry(),
71
>
task.GetNamespaceID(),
72
>
executable.GetWorkflowID(),
73
>
)
74
>
taskType := queues.GetOutboundTaskTypeTagValue(task, true, e.shardContext.ChasmRegistry())
75
>
respond := func(err error) queues.ExecuteResponse {
76
>
metricsTags := []metrics.Tag{
77
>
namespaceTag,
78
>
metrics.TaskTypeTag(taskType),
79
>
metrics.OperationTag(taskType),
80
>
}
81
>
return queues.ExecuteResponse{
82
>
ExecutionMetricTags: metricsTags,
83
>
ExecutedAsActive: true,
84
>
ExecutionErr: err,
85
>
}
86
>
}
87
88
// We don't want to execute outbound tasks when handing over a namespace to avoid starting work that may not be