88
// between retry attempts.
89
// This method will be invoked after a workflow passes its retention period.
90
>
func (h *historyArchiver) Archive(ctx context.Context, URI archiver.URI, request *archiver.ArchiveHistoryRequest, opts ...archiver.ArchiveOption) (err error) {
history_archiver.go
91
>
handler := h.metricsHandler.WithTags(metrics.OperationTag(metrics.HistoryArchiverScope), metrics.NamespaceTag(request.Namespace))
92
>
featureCatalog := archiver.GetFeatureCatalog(opts...)
93
>
startTime := time.Now().UTC()
94
>
defer func() {
95
>
metrics.ServiceLatency.With(handler).Record(time.Since(startTime))
96
>
if err != nil {
97
98
if err.Error() != errUploadNonRetryable.Error() {