387
}
388
389
>
if namespaceEntry, err := shardContext.GetNamespaceRegistry().GetNamespaceByID(
transaction_impl.go
390
>
namespace.ID(request.NewWorkflowSnapshot.ExecutionInfo.NamespaceId),
391
>
); err == nil {
392
>
emitMutationMetrics(
393
>
shardContext,
394
>
namespaceEntry,
395
>
request.ArchetypeID,
396
>
&resp.NewMutableStateStats,
397
>
)
398
>
emitCompletionMetrics(
399
>
shardContext,
400
>
namespaceEntry,
401
>
snapshotToCompletionMetric(
402
>
namespaceState(shardContext.GetClusterMetadata(), &mutableStateFailoverVersion),
403
>
&request.NewWorkflowSnapshot,
404
>
request.NewWorkflowEvents,
405
>
isWorkflow,
406
>
),
407
>
)
408
>
}
409
>
return resp, nil
410
}
411