From e1ed05cb0807a00e330f32f77db8202e56779a3e Mon Sep 17 00:00:00 2001 From: Dan Douglas Date: Mon, 6 Nov 2023 13:02:12 -0800 Subject: [PATCH] dang... flipped success/failure metrics during the refactor --- pkg/pipeline/sink/uploader/uploader.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/pipeline/sink/uploader/uploader.go b/pkg/pipeline/sink/uploader/uploader.go index a50e0df8..c5b05644 100644 --- a/pkg/pipeline/sink/uploader/uploader.go +++ b/pkg/pipeline/sink/uploader/uploader.go @@ -83,14 +83,14 @@ func (u *remoteUploader) Upload(localFilepath, storageFilepath string, outputTyp location, size, err := u.upload(localFilepath, storageFilepath, outputType) elapsed := time.Since(start).Milliseconds() if err == nil { - u.monitor.IncUploadCountFailure(fileType, float64(elapsed)) + u.monitor.IncUploadCountSuccess(fileType, float64(elapsed)) if deleteAfterUpload { _ = os.Remove(localFilepath) } return location, size, nil } - u.monitor.IncUploadCountSuccess(fileType, float64(elapsed)) + u.monitor.IncUploadCountFailure(fileType, float64(elapsed)) if u.backup != "" { stat, err := os.Stat(localFilepath)