Skip to content

Commit a0e5711

Browse files
Shaddollins-tril
authored andcommitted
Reset update queue state timer on failure (cadence-workflow#7194)
1 parent ef889e1 commit a0e5711

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)