Skip to content

Commit 43ced55

Browse files
authored
Add complete history tasks metric (#7234)
1 parent d08c141 commit 43ced55

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

service/history/queuev2/queue_base.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -295,7 +295,9 @@ func (q *queueBase) updateQueueState(ctx context.Context) {
295295
// TODO: review the metrics and remove this comment or change the metric from gauge to histogram
296296
q.metricsScope.UpdateGauge(metrics.PendingTaskGauge, float64(pendingTaskCount))
297297

298+
q.logger.Debug("complete history tasks", tag.Dynamic("oldExclusiveAckLevel", q.exclusiveAckLevel), tag.Dynamic("newExclusiveAckLevel", newExclusiveAckLevel))
298299
if newExclusiveAckLevel.Compare(q.exclusiveAckLevel) > 0 {
300+
q.metricsScope.IncCounter(metrics.TaskBatchCompleteCounter)
299301
inclusiveMinTaskKey := q.exclusiveAckLevel
300302
exclusiveMaxTaskKey := newExclusiveAckLevel
301303
if q.category.Type() == persistence.HistoryTaskCategoryTypeScheduled {

0 commit comments

Comments
 (0)