From 1744b94cef3c966c9df3bcc2a0ddb1bf08a67d2a Mon Sep 17 00:00:00 2001 From: rasmus Date: Sun, 6 Nov 2022 16:35:49 +0200 Subject: [PATCH] fix catchupped metric --- cmd/submit.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/submit.go b/cmd/submit.go index 89f0713..24b30ea 100644 --- a/cmd/submit.go +++ b/cmd/submit.go @@ -124,7 +124,7 @@ func (s *submitter) shipFileRoutine(ctx context.Context, name string, sendQueue } if !catchUpped { - catchUpped = line.EndOffset > startSize + catchUpped = line.EndOffset >= startSize if catchUpped { promCatchupDone.WithLabelValues(baseName).Set(1)