Skip to content

Commit 848d766

Browse files
authored
Reset update queue state timer on failure (#7194)
1 parent 5560d51 commit 848d766

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

service/history/queuev2/queue_base.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -313,6 +313,10 @@ func (q *queueBase) updateQueueState(ctx context.Context) {
313313
})
314314
if err != nil {
315315
q.logger.Error("Failed to range complete history tasks", tag.Error(err))
316+
q.updateQueueStateTimer.Reset(backoff.JitDuration(
317+
q.options.UpdateAckInterval(),
318+
q.options.UpdateAckIntervalJitterCoefficient(),
319+
))
316320
return
317321
}
318322
if !persistence.HasMoreRowsToDelete(resp.TasksCompleted, pageSize) {

0 commit comments

Comments
 (0)