diff --git a/internal/services/syncservice/handler.go b/internal/services/syncservice/handler.go index 89637eb6..160112e0 100644 --- a/internal/services/syncservice/handler.go +++ b/internal/services/syncservice/handler.go @@ -188,7 +188,7 @@ func (t *Handler) run(ctx context.Context, syncStatus.TotalMessageCount = totalMessageCount } - syncReporter.InitializeProgressCounter(ctx, syncStatus.NumSyncedMessages, syncStatus.TotalMessageCount*NumSyncStages) + syncReporter.InitializeProgressCounter(ctx, syncStatus.NumSyncedMessages*NumSyncStages, syncStatus.TotalMessageCount*NumSyncStages) if !syncStatus.HasMessages { t.log.Info("Syncing messages")