reset updated time after each update

samarabbas · samarabbas · commit 4645f0f818cf · 2017-09-26T14:07:58.000-07:00
diff --git a/service/history/timerQueueProcessor.go b/service/history/timerQueueProcessor.go
@@ -999,5 +999,7 @@ MoveAckLevelLoop:
 	if err := t.shard.UpdateTimerAckLevel(updatedAckLevel); err != nil {
 		t.metricsClient.IncCounter(metrics.TimerQueueProcessorScope, metrics.AckLevelUpdateFailedCounter)
 		t.logger.Errorf("Error updating timer ack level for shard: %v", err)
+	} else {
+		t.lastUpdated = time.Now()
 	}
 }
diff --git a/service/history/transferQueueProcessor.go b/service/history/transferQueueProcessor.go
@@ -950,8 +950,9 @@ MoveAckLevelLoop:
 	if err := a.shard.UpdateTransferAckLevel(updatedAckLevel); err != nil {
 		a.metricsClient.IncCounter(metrics.TransferQueueProcessorScope, metrics.AckLevelUpdateFailedCounter)
 		logging.LogOperationFailedEvent(a.logger, "Error updating ack level for shard", err)
+	} else {
+		a.lastUpdated = time.Now()
 	}
-
 }
 
 func minDuration(x, y time.Duration) time.Duration {

Original file line number	Diff line number	Diff line change
`@@ -999,5 +999,7 @@ MoveAckLevelLoop:`
`999`	`999`	`if err := t.shard.UpdateTimerAckLevel(updatedAckLevel); err != nil {`
`1000`	`1000`	`t.metricsClient.IncCounter(metrics.TimerQueueProcessorScope, metrics.AckLevelUpdateFailedCounter)`
`1001`	`1001`	`t.logger.Errorf("Error updating timer ack level for shard: %v", err)`
	`1002`	`+ } else {`
	`1003`	`+ t.lastUpdated = time.Now()`
`1002`	`1004`	`}`
`1003`	`1005`	`}`
Original file line number	Diff line number	Diff line change
`@@ -950,8 +950,9 @@ MoveAckLevelLoop:`
`950`	`950`	`if err := a.shard.UpdateTransferAckLevel(updatedAckLevel); err != nil {`
`951`	`951`	`a.metricsClient.IncCounter(metrics.TransferQueueProcessorScope, metrics.AckLevelUpdateFailedCounter)`
`952`	`952`	`logging.LogOperationFailedEvent(a.logger, "Error updating ack level for shard", err)`
	`953`	`+ } else {`
	`954`	`+ a.lastUpdated = time.Now()`
`953`	`955`	`}`
`954`		`-`
`955`	`956`	`}`
`956`	`957`
`957`	`958`	`func minDuration(x, y time.Duration) time.Duration {`