1929
}
1930
1931
>
func (a *Activity) enrichMetricsHandler(ctx chasm.Context, operationTag string) (metrics.Handler, error) {
activity.go
1932
>
// activityContextFromChasm panics if the context value is missing; this is intentional and
1933
>
// indicates a library registration bug rather than a runtime error.
1934
>
actCtx := activityContextFromChasm(ctx)
1935
>
namespaceName, err := actCtx.namespaceRegistry.GetNamespaceName(namespace.ID(ctx.ExecutionKey().NamespaceID))
1936
>
if err != nil {
1937
return nil, err
1938
}
1939
>
breakdownMetricsByTaskQueue := actCtx.config.BreakdownMetricsByTaskQueue
activity.go
1940
>
taskQueueFamily := a.GetTaskQueue().GetName()
1941
>
return metrics.GetPerTaskQueueFamilyScope(
1942
>
ctx.MetricsHandler(),
1943
>
namespaceName.String(),
1944
>
tqid.UnsafeTaskQueueFamily(namespaceName.String(), taskQueueFamily),
1945
>
breakdownMetricsByTaskQueue(namespaceName.String(), taskQueueFamily, enumspb.TASK_QUEUE_TYPE_ACTIVITY),
1946
>
metrics.OperationTag(operationTag),
1947
>
metrics.ActivityTypeTag(a.GetActivityType().GetName()),
1948
>
metrics.VersioningBehaviorTag(enumspb.VERSIONING_BEHAVIOR_UNSPECIFIED),
1949
>
metrics.WorkflowTypeTag(WorkflowTypeTag),
1950
>
), nil
1951
}
1952