131
132
if err == nil {
133
>
workflow.RecordActivityCompletionMetrics(
api.go
134
>
shard,
135
>
namespaceName,
136
>
taskQueue,
137
>
workflow.ActivityCompletionMetrics{
138
>
AttemptStartedTime: attemptStartedTime,
139
>
FirstScheduledTime: firstScheduledTime,
140
>
Status: workflow.ActivityStatusSucceeded,
141
>
Closed: true,
142
>
},
143
>
metrics.OperationTag(metrics.HistoryRespondActivityTaskCompletedScope),
144
>
metrics.WorkflowTypeTag(workflowTypeName),
145
>
metrics.ActivityTypeTag(token.ActivityType),
146
>
metrics.VersioningBehaviorTag(versioningBehavior),
147
>
)
148
>
}
149
return &historyservice.RespondActivityTaskCompletedResponse{}, err
150
}