369
ctx context.Context,
370
request *GetCurrentExecutionRequest,
372
>
caller := headers.GetCallerInfo(ctx).CallerName
373
>
startTime := time.Now().UTC()
374
>
defer func() {
375
>
p.healthSignals.Record(request.ShardID, time.Since(startTime), retErr)
376
>
var workflowID, runID string
377
>
if request != nil {
378
>
workflowID = request.WorkflowID
379
>
}
380
>
p.recordRequestMetrics(metrics.PersistenceGetCurrentExecutionScope, caller, time.Since(startTime), retErr)
381
>
p.recordDataLossMetrics(metrics.PersistenceGetCurrentExecutionScope, caller, retErr, workflowID, runID)
382
}()
384
}
385