252
ctx context.Context,
253
request *GetWorkflowExecutionRequest,
255
>
caller := headers.GetCallerInfo(ctx).CallerName
256
>
startTime := time.Now().UTC()
257
>
defer func() {
258
>
p.healthSignals.Record(request.ShardID, time.Since(startTime), retErr)
259
>
var workflowID, runID string
260
>
if request != nil {
261
>
workflowID = request.WorkflowID
262
>
runID = request.RunID
263
>
}
264
>
p.recordRequestMetrics(metrics.PersistenceGetWorkflowExecutionScope, caller, time.Since(startTime), retErr)
265
>
p.recordDataLossMetrics(metrics.PersistenceGetWorkflowExecutionScope, caller, retErr, workflowID, runID)
266
}()
268
}
269