mirror of
https://github.com/hanzoai/tasks.git
synced 2026-10-04 02:04:03 +00:00
michaely520andGitHub
65bab60197
## What changed? Errors that occur prior to the telemetry interceptor are not captured, meaning there is no log, the request isn't counted, and the error isn't counted. I've extracted the telemetry interceptors error handling into a shared obj that I've wired into the NamespaceHandover error handling for now. An alternative approach was to move the TelemetryInterceptor earlier in the chain, but this would have caused double counting on redirects, and adding another dimension to our metrics (pre/post redirect) here to address the double counting would cause other classes of issues As of now, other interceptors that are added prior to the TelemetryInterceptor are also at risk of this. We can wrap PreTelemetry errors and have a new interceptor handle these if we want to more generically address this issue - view my commit history for "Experimental" (which I reverted) to see an example of this. ## Why? To specifically track metrics/logs on NamespaceHandover failures. ## How did you test it? - [x] built - [ ] run locally and tested manually - [ ] covered by existing tests - [ ] added new unit test(s) - [ ] added new functional test(s) ## Potential risks Potential metrics loss if for some reason telemetry metric error handling is not wired correctly after the refactor.
549 lines
18 KiB
Go
549 lines
18 KiB
Go
package interceptor
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
commandpb "go.temporal.io/api/command/v1"
|
|
commonpb "go.temporal.io/api/common/v1"
|
|
enumspb "go.temporal.io/api/enums/v1"
|
|
protocolpb "go.temporal.io/api/protocol/v1"
|
|
querypb "go.temporal.io/api/query/v1"
|
|
"go.temporal.io/api/serviceerror"
|
|
workflowpb "go.temporal.io/api/workflow/v1"
|
|
"go.temporal.io/api/workflowservice/v1"
|
|
"go.temporal.io/server/api/historyservice/v1"
|
|
"go.temporal.io/server/common/api"
|
|
"go.temporal.io/server/common/dynamicconfig"
|
|
"go.temporal.io/server/common/log"
|
|
"go.temporal.io/server/common/log/tag"
|
|
"go.temporal.io/server/common/metrics"
|
|
"go.temporal.io/server/common/namespace"
|
|
serviceerrors "go.temporal.io/server/common/serviceerror"
|
|
"go.uber.org/mock/gomock"
|
|
"google.golang.org/grpc/codes"
|
|
"google.golang.org/grpc/status"
|
|
)
|
|
|
|
const (
|
|
startWorkflow = "StartWorkflowExecution"
|
|
executeMultiOps = "ExecuteMultiOperation"
|
|
)
|
|
|
|
func TestEmitActionMetric(t *testing.T) {
|
|
controller := gomock.NewController(t)
|
|
register := namespace.NewMockRegistry(controller)
|
|
metricsHandler := metrics.NewMockHandler(controller)
|
|
logger := log.NewNoopLogger()
|
|
logAllReqErrors := dynamicconfig.GetBoolPropertyFnFilteredByNamespace(false)
|
|
requestErrorHandler := NewMockErrorHandler(controller)
|
|
telemetry := NewTelemetryInterceptor(register,
|
|
metricsHandler,
|
|
logger,
|
|
logAllReqErrors,
|
|
requestErrorHandler)
|
|
|
|
testCases := []struct {
|
|
methodName string
|
|
fullName string
|
|
expectEmitMetrics bool
|
|
req any
|
|
resp any
|
|
}{
|
|
{
|
|
methodName: startWorkflow,
|
|
fullName: api.WorkflowServicePrefix + startWorkflow,
|
|
resp: &workflowservice.StartWorkflowExecutionResponse{Started: false},
|
|
},
|
|
{
|
|
methodName: startWorkflow,
|
|
fullName: api.WorkflowServicePrefix + startWorkflow,
|
|
resp: &workflowservice.StartWorkflowExecutionResponse{Started: true},
|
|
expectEmitMetrics: true,
|
|
},
|
|
{
|
|
methodName: startWorkflow,
|
|
fullName: api.WorkflowServicePrefix + startWorkflow,
|
|
req: &workflowservice.StartWorkflowExecutionRequest{
|
|
Namespace: "test-namespace",
|
|
OnConflictOptions: &workflowpb.OnConflictOptions{},
|
|
WorkflowIdConflictPolicy: enumspb.WORKFLOW_ID_CONFLICT_POLICY_USE_EXISTING,
|
|
},
|
|
resp: &workflowservice.StartWorkflowExecutionResponse{Started: false},
|
|
expectEmitMetrics: true,
|
|
},
|
|
{
|
|
methodName: executeMultiOps,
|
|
fullName: api.WorkflowServicePrefix + executeMultiOps,
|
|
resp: &workflowservice.ExecuteMultiOperationResponse{
|
|
Responses: []*workflowservice.ExecuteMultiOperationResponse_Response{
|
|
{
|
|
Response: &workflowservice.ExecuteMultiOperationResponse_Response_StartWorkflow{
|
|
StartWorkflow: &workflowservice.StartWorkflowExecutionResponse{
|
|
Started: false,
|
|
},
|
|
},
|
|
},
|
|
{
|
|
Response: &workflowservice.ExecuteMultiOperationResponse_Response_UpdateWorkflow{
|
|
UpdateWorkflow: &workflowservice.UpdateWorkflowExecutionResponse{},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
{
|
|
methodName: executeMultiOps,
|
|
fullName: api.WorkflowServicePrefix + executeMultiOps,
|
|
resp: &workflowservice.ExecuteMultiOperationResponse{
|
|
Responses: []*workflowservice.ExecuteMultiOperationResponse_Response{
|
|
{
|
|
Response: &workflowservice.ExecuteMultiOperationResponse_Response_StartWorkflow{
|
|
StartWorkflow: &workflowservice.StartWorkflowExecutionResponse{
|
|
Started: true,
|
|
},
|
|
},
|
|
},
|
|
{
|
|
Response: &workflowservice.ExecuteMultiOperationResponse_Response_UpdateWorkflow{
|
|
UpdateWorkflow: &workflowservice.UpdateWorkflowExecutionResponse{},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
expectEmitMetrics: true,
|
|
},
|
|
{
|
|
methodName: executeMultiOps,
|
|
fullName: api.WorkflowServicePrefix + executeMultiOps,
|
|
resp: &workflowservice.ExecuteMultiOperationResponse{
|
|
Responses: []*workflowservice.ExecuteMultiOperationResponse_Response{
|
|
{
|
|
Response: &workflowservice.ExecuteMultiOperationResponse_Response_StartWorkflow{
|
|
StartWorkflow: &workflowservice.StartWorkflowExecutionResponse{
|
|
Started: false,
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
req: &workflowservice.ExecuteMultiOperationRequest{
|
|
Namespace: "test-namespace",
|
|
Operations: []*workflowservice.ExecuteMultiOperationRequest_Operation{
|
|
{
|
|
Operation: &workflowservice.ExecuteMultiOperationRequest_Operation_StartWorkflow{
|
|
StartWorkflow: &workflowservice.StartWorkflowExecutionRequest{
|
|
Namespace: "test-namespace",
|
|
OnConflictOptions: &workflowpb.OnConflictOptions{},
|
|
WorkflowIdConflictPolicy: enumspb.WORKFLOW_ID_CONFLICT_POLICY_USE_EXISTING,
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
expectEmitMetrics: true,
|
|
},
|
|
{
|
|
methodName: executeMultiOps,
|
|
fullName: api.WorkflowServicePrefix + executeMultiOps,
|
|
resp: &workflowservice.ExecuteMultiOperationResponse{
|
|
Responses: []*workflowservice.ExecuteMultiOperationResponse_Response{
|
|
// missing start response
|
|
{
|
|
Response: &workflowservice.ExecuteMultiOperationResponse_Response_UpdateWorkflow{
|
|
UpdateWorkflow: &workflowservice.UpdateWorkflowExecutionResponse{},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
{
|
|
methodName: executeMultiOps,
|
|
fullName: api.WorkflowServicePrefix + executeMultiOps,
|
|
resp: &workflowservice.ExecuteMultiOperationResponse{
|
|
Responses: []*workflowservice.ExecuteMultiOperationResponse_Response{
|
|
// no responses
|
|
},
|
|
},
|
|
},
|
|
{
|
|
methodName: queryWorkflow,
|
|
fullName: api.AdminServicePrefix + queryWorkflow,
|
|
},
|
|
{
|
|
methodName: metrics.MatchingClientAddWorkflowTaskScope,
|
|
fullName: api.WorkflowServicePrefix + queryWorkflow,
|
|
},
|
|
{
|
|
methodName: "UpdateWorkflowExecution",
|
|
fullName: api.WorkflowServicePrefix + queryWorkflow,
|
|
}, {
|
|
methodName: metrics.HistoryRespondWorkflowTaskCompletedScope,
|
|
fullName: api.WorkflowServicePrefix + "RespondWorkflowTaskCompleted",
|
|
req: &workflowservice.RespondWorkflowTaskCompletedRequest{
|
|
Messages: []*protocolpb.Message{
|
|
{
|
|
Id: "MESSAGE_ID",
|
|
Body: &updateAcceptanceMessageBody,
|
|
},
|
|
},
|
|
},
|
|
expectEmitMetrics: true,
|
|
},
|
|
{
|
|
methodName: metrics.HistoryRespondWorkflowTaskCompletedScope,
|
|
fullName: api.WorkflowServicePrefix + "RespondWorkflowTaskCompleted",
|
|
req: &workflowservice.RespondWorkflowTaskCompletedRequest{
|
|
Commands: []*commandpb.Command{
|
|
{
|
|
CommandType: enumspb.COMMAND_TYPE_SCHEDULE_NEXUS_OPERATION,
|
|
},
|
|
},
|
|
},
|
|
expectEmitMetrics: true,
|
|
},
|
|
{
|
|
methodName: metrics.HistoryRespondWorkflowTaskCompletedScope,
|
|
fullName: api.WorkflowServicePrefix + "RespondWorkflowTaskCompleted",
|
|
req: &workflowservice.RespondWorkflowTaskCompletedRequest{
|
|
Messages: []*protocolpb.Message{
|
|
{
|
|
Id: "MESSAGE_ID",
|
|
Body: &updateRejectionMessageBody,
|
|
},
|
|
},
|
|
},
|
|
expectEmitMetrics: true,
|
|
},
|
|
{
|
|
methodName: metrics.HistoryRespondWorkflowTaskCompletedScope,
|
|
fullName: api.WorkflowServicePrefix + "RespondWorkflowTaskCompleted",
|
|
req: &workflowservice.RespondWorkflowTaskCompletedRequest{
|
|
Messages: []*protocolpb.Message{
|
|
{
|
|
Id: "MESSAGE_ID",
|
|
Body: &updateResponseMessageBody,
|
|
},
|
|
},
|
|
},
|
|
},
|
|
{
|
|
methodName: queryWorkflow,
|
|
fullName: api.WorkflowServicePrefix + queryWorkflow,
|
|
req: &workflowservice.QueryWorkflowRequest{
|
|
Query: &querypb.WorkflowQuery{
|
|
QueryType: "some_type",
|
|
},
|
|
},
|
|
expectEmitMetrics: true,
|
|
},
|
|
{
|
|
methodName: updateWorkflowExecutionOptions,
|
|
fullName: api.WorkflowServicePrefix + updateWorkflowExecutionOptions,
|
|
req: &workflowservice.UpdateWorkflowExecutionOptionsRequest{
|
|
Namespace: "test-namespace",
|
|
WorkflowExecution: &commonpb.WorkflowExecution{
|
|
WorkflowId: "test-workflow-id",
|
|
RunId: "test-run-id",
|
|
},
|
|
WorkflowExecutionOptions: &workflowpb.WorkflowExecutionOptions{
|
|
VersioningOverride: &workflowpb.VersioningOverride{
|
|
Behavior: enumspb.VERSIONING_BEHAVIOR_PINNED,
|
|
PinnedVersion: "fake-version",
|
|
},
|
|
},
|
|
},
|
|
expectEmitMetrics: true,
|
|
},
|
|
{
|
|
methodName: queryWorkflow,
|
|
fullName: api.WorkflowServicePrefix + queryWorkflow,
|
|
req: &workflowservice.QueryWorkflowRequest{
|
|
Query: &querypb.WorkflowQuery{
|
|
QueryType: "__temporal_workflow_metadata",
|
|
},
|
|
},
|
|
},
|
|
}
|
|
|
|
for _, tt := range testCases {
|
|
t.Run(tt.methodName, func(t *testing.T) {
|
|
if tt.expectEmitMetrics {
|
|
metricsHandler.EXPECT().Counter(metrics.ActionCounter.Name()).Return(metrics.NoopCounterMetricFunc).Times(1)
|
|
} else {
|
|
metricsHandler.EXPECT().Counter(metrics.ActionCounter.Name()).Return(metrics.NoopCounterMetricFunc).Times(0)
|
|
}
|
|
telemetry.emitActionMetric(tt.methodName, tt.fullName, tt.req, metricsHandler, tt.resp)
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestHandleError(t *testing.T) {
|
|
controller := gomock.NewController(t)
|
|
mockLogger := log.NewMockLogger(controller)
|
|
metricsHandler := metrics.NewMockHandler(controller)
|
|
|
|
testCases := []struct {
|
|
name string
|
|
err error
|
|
expectLogging bool
|
|
ServiceFailuresCount int
|
|
ServiceErrorWithTypeCount int
|
|
ResourceExhaustedCount int
|
|
logAllErrors dynamicconfig.BoolPropertyFnWithNamespaceFilter
|
|
}{
|
|
{
|
|
name: "serviceerror-invalid-argument",
|
|
err: serviceerror.NewInvalidArgument("invalid argument"),
|
|
expectLogging: false,
|
|
ServiceFailuresCount: 0,
|
|
ResourceExhaustedCount: 0,
|
|
ServiceErrorWithTypeCount: 1,
|
|
logAllErrors: dynamicconfig.GetBoolPropertyFnFilteredByNamespace(false),
|
|
},
|
|
{
|
|
name: "serviceerror-invalid-argument-log-all",
|
|
err: serviceerror.NewInvalidArgument("invalid argument"),
|
|
expectLogging: true,
|
|
ServiceFailuresCount: 0,
|
|
ResourceExhaustedCount: 0,
|
|
ServiceErrorWithTypeCount: 1,
|
|
logAllErrors: dynamicconfig.GetBoolPropertyFnFilteredByNamespace(true),
|
|
},
|
|
{
|
|
name: "statuserror-invalid-argument",
|
|
err: status.Error(codes.InvalidArgument, "invalid argument"),
|
|
expectLogging: false,
|
|
ServiceFailuresCount: 0,
|
|
ResourceExhaustedCount: 0,
|
|
ServiceErrorWithTypeCount: 1,
|
|
logAllErrors: dynamicconfig.GetBoolPropertyFnFilteredByNamespace(false),
|
|
},
|
|
{
|
|
name: "statuserror-invalid-argument-log-all",
|
|
err: status.Error(codes.InvalidArgument, "invalid argument"),
|
|
expectLogging: true,
|
|
ServiceFailuresCount: 0,
|
|
ResourceExhaustedCount: 0,
|
|
ServiceErrorWithTypeCount: 1,
|
|
logAllErrors: dynamicconfig.GetBoolPropertyFnFilteredByNamespace(true),
|
|
},
|
|
{
|
|
name: "serviceerror-internal",
|
|
err: serviceerror.NewInternal("internal"),
|
|
expectLogging: true,
|
|
ServiceFailuresCount: 1,
|
|
ResourceExhaustedCount: 0,
|
|
ServiceErrorWithTypeCount: 1,
|
|
logAllErrors: dynamicconfig.GetBoolPropertyFnFilteredByNamespace(false),
|
|
},
|
|
{
|
|
name: "serviceerror-internal-log-all",
|
|
err: serviceerror.NewInternal("internal"),
|
|
expectLogging: true,
|
|
ServiceFailuresCount: 1,
|
|
ResourceExhaustedCount: 0,
|
|
ServiceErrorWithTypeCount: 1,
|
|
logAllErrors: dynamicconfig.GetBoolPropertyFnFilteredByNamespace(true),
|
|
},
|
|
{
|
|
name: "statuserror-internal",
|
|
err: status.Error(codes.Internal, "internal"),
|
|
expectLogging: true,
|
|
ServiceFailuresCount: 1,
|
|
ResourceExhaustedCount: 0,
|
|
ServiceErrorWithTypeCount: 1,
|
|
logAllErrors: dynamicconfig.GetBoolPropertyFnFilteredByNamespace(false),
|
|
},
|
|
{
|
|
name: "statuserror-internal-log-all",
|
|
err: status.Error(codes.Internal, "internal"),
|
|
expectLogging: true,
|
|
ServiceFailuresCount: 1,
|
|
ResourceExhaustedCount: 0,
|
|
ServiceErrorWithTypeCount: 1,
|
|
logAllErrors: dynamicconfig.GetBoolPropertyFnFilteredByNamespace(true),
|
|
},
|
|
{
|
|
name: "resource-exhausted-system",
|
|
err: &serviceerror.ResourceExhausted{
|
|
Message: "resource exhausted",
|
|
Cause: enumspb.RESOURCE_EXHAUSTED_CAUSE_UNSPECIFIED,
|
|
Scope: enumspb.RESOURCE_EXHAUSTED_SCOPE_SYSTEM,
|
|
},
|
|
expectLogging: false,
|
|
ServiceFailuresCount: 1,
|
|
ResourceExhaustedCount: 1,
|
|
ServiceErrorWithTypeCount: 1,
|
|
logAllErrors: dynamicconfig.GetBoolPropertyFnFilteredByNamespace(false),
|
|
},
|
|
{
|
|
name: "resource-exhausted-namespace",
|
|
err: &serviceerror.ResourceExhausted{
|
|
Message: "resource exhausted",
|
|
Cause: enumspb.RESOURCE_EXHAUSTED_CAUSE_UNSPECIFIED,
|
|
Scope: enumspb.RESOURCE_EXHAUSTED_SCOPE_NAMESPACE,
|
|
},
|
|
expectLogging: true,
|
|
ServiceFailuresCount: 0,
|
|
ResourceExhaustedCount: 1,
|
|
ServiceErrorWithTypeCount: 1,
|
|
logAllErrors: dynamicconfig.GetBoolPropertyFnFilteredByNamespace(true),
|
|
},
|
|
{
|
|
name: "canceled",
|
|
err: context.Canceled,
|
|
expectLogging: false,
|
|
ServiceFailuresCount: 0,
|
|
ResourceExhaustedCount: 0,
|
|
ServiceErrorWithTypeCount: 1,
|
|
logAllErrors: dynamicconfig.GetBoolPropertyFnFilteredByNamespace(false),
|
|
},
|
|
{
|
|
name: "deadline-exceeded",
|
|
err: context.DeadlineExceeded,
|
|
expectLogging: true,
|
|
ServiceFailuresCount: 1,
|
|
ResourceExhaustedCount: 0,
|
|
ServiceErrorWithTypeCount: 1,
|
|
logAllErrors: dynamicconfig.GetBoolPropertyFnFilteredByNamespace(true),
|
|
},
|
|
{
|
|
name: "shard-ownership-lost",
|
|
err: serviceerrors.NewShardOwnershipLost("shard ownership lost", "hostname"),
|
|
expectLogging: true,
|
|
ServiceFailuresCount: 1,
|
|
ResourceExhaustedCount: 0,
|
|
ServiceErrorWithTypeCount: 1,
|
|
logAllErrors: dynamicconfig.GetBoolPropertyFnFilteredByNamespace(false),
|
|
},
|
|
}
|
|
|
|
for _, tt := range testCases {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
metricsHandler.EXPECT().Counter(metrics.ServiceFailures.Name()).Return(metrics.NoopCounterMetricFunc).Times(tt.ServiceFailuresCount)
|
|
metricsHandler.EXPECT().Counter(metrics.ServiceErrorWithType.Name()).Return(metrics.NoopCounterMetricFunc).Times(tt.ServiceErrorWithTypeCount)
|
|
metricsHandler.EXPECT().Counter(metrics.ServiceErrResourceExhaustedCounter.Name()).Return(metrics.NoopCounterMetricFunc).Times(tt.ResourceExhaustedCount)
|
|
|
|
requestErrorHandler := NewRequestErrorHandler(mockLogger, tt.logAllErrors)
|
|
|
|
if tt.expectLogging {
|
|
mockLogger.EXPECT().Error(gomock.Eq("service failures"), gomock.Any()).Times(1)
|
|
} else {
|
|
mockLogger.EXPECT().Error(gomock.Eq("service failures"), gomock.Any()).Times(0)
|
|
}
|
|
|
|
requestErrorHandler.HandleError(nil,
|
|
"",
|
|
metricsHandler,
|
|
[]tag.Tag{},
|
|
tt.err,
|
|
"test")
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestOperationOverwrite(t *testing.T) {
|
|
testCases := []struct {
|
|
methodName string
|
|
fullName string
|
|
expectedOperation string
|
|
}{
|
|
{
|
|
"DeleteWorkflowExecution",
|
|
api.AdminServicePrefix + "DeleteWorkflowExecution",
|
|
"AdminDeleteWorkflowExecution",
|
|
},
|
|
{
|
|
"DeleteNamespace",
|
|
api.OperatorServicePrefix + "DeleteNamespace",
|
|
"OperatorDeleteNamespace",
|
|
},
|
|
{
|
|
startWorkflow,
|
|
api.WorkflowServicePrefix + startWorkflow,
|
|
startWorkflow,
|
|
},
|
|
}
|
|
|
|
for _, tt := range testCases {
|
|
t.Run(tt.methodName, func(t *testing.T) {
|
|
operation := telemetryOverrideOperationTag(tt.fullName, tt.methodName)
|
|
assert.Equal(t, tt.expectedOperation, operation)
|
|
})
|
|
}
|
|
}
|
|
|
|
func TestOperationOverride(t *testing.T) {
|
|
wid := "test_workflow_id"
|
|
rid := "test_run_id"
|
|
|
|
testCases := []struct {
|
|
methodName string
|
|
fullName string
|
|
req interface{}
|
|
expectedOperation string
|
|
}{
|
|
{
|
|
"GetWorkflowExecutionHistory",
|
|
api.WorkflowServicePrefix + "GetWorkflowExecutionHistory",
|
|
&workflowservice.GetWorkflowExecutionHistoryRequest{
|
|
Execution: &commonpb.WorkflowExecution{
|
|
WorkflowId: wid,
|
|
RunId: rid,
|
|
},
|
|
WaitNewEvent: false,
|
|
},
|
|
"GetWorkflowExecutionHistory",
|
|
},
|
|
{
|
|
"GetWorkflowExecutionHistory",
|
|
api.WorkflowServicePrefix + "GetWorkflowExecutionHistory",
|
|
&workflowservice.GetWorkflowExecutionHistoryRequest{
|
|
Execution: &commonpb.WorkflowExecution{
|
|
WorkflowId: wid,
|
|
RunId: rid,
|
|
},
|
|
WaitNewEvent: true,
|
|
},
|
|
"PollWorkflowExecutionHistory",
|
|
},
|
|
{
|
|
"GetWorkflowExecutionHistory",
|
|
api.HistoryServicePrefix + "GetWorkflowExecutionHistory",
|
|
&historyservice.GetWorkflowExecutionHistoryRequest{
|
|
Request: &workflowservice.GetWorkflowExecutionHistoryRequest{
|
|
Execution: &commonpb.WorkflowExecution{
|
|
WorkflowId: wid,
|
|
RunId: rid,
|
|
},
|
|
WaitNewEvent: false,
|
|
},
|
|
},
|
|
"GetWorkflowExecutionHistory",
|
|
},
|
|
{
|
|
"GetWorkflowExecutionHistory",
|
|
api.HistoryServicePrefix + "GetWorkflowExecutionHistory",
|
|
&historyservice.GetWorkflowExecutionHistoryRequest{
|
|
Request: &workflowservice.GetWorkflowExecutionHistoryRequest{
|
|
Execution: &commonpb.WorkflowExecution{
|
|
WorkflowId: wid,
|
|
RunId: rid,
|
|
},
|
|
WaitNewEvent: true,
|
|
},
|
|
},
|
|
"PollWorkflowExecutionHistory",
|
|
},
|
|
}
|
|
|
|
for _, tt := range testCases {
|
|
t.Run(tt.methodName, func(t *testing.T) {
|
|
operation := telemetryUnaryOverrideOperationTag(tt.fullName, tt.methodName, tt.req)
|
|
assert.Equal(t, tt.expectedOperation, operation)
|
|
})
|
|
}
|
|
}
|