From 6bc0fb4d90da20c87c835d015d692042d7edf5bc Mon Sep 17 00:00:00 2001 From: Chang lue Tsen Date: Thu, 11 Sep 2025 06:29:12 -0400 Subject: [PATCH] fix(quota): update taskInfo to include current subscription count in quota logic --- queue/logic/task/quotaLogic.go | 1 + 1 file changed, 1 insertion(+) diff --git a/queue/logic/task/quotaLogic.go b/queue/logic/task/quotaLogic.go index 0ea9297..a103193 100644 --- a/queue/logic/task/quotaLogic.go +++ b/queue/logic/task/quotaLogic.go @@ -208,6 +208,7 @@ func (l *QuotaTaskLogic) processSubscribes(ctx context.Context, subscribes []*us taskInfo.Errors = string(errs) } + taskInfo.Current = uint64(len(subscribes)) taskInfo.Status = status err := tx.Where("id = ?", taskInfo.Id).Save(taskInfo).Error if err != nil {