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