Fix logging in OrderBookStream (#2699)

stellar · Jun 17, 2020 · c157ce9 · c157ce9
1 parent 2ed3ba3
commit c157ce9
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/services/horizon/internal/expingest/orderbook.go b/services/horizon/internal/expingest/orderbook.go
@@ -103,9 +103,13 @@ func addOfferToGraph(graph orderbook.OBGraph, offer history.Offer) {
 // update returns true if the order book graph was reset
 func (o *OrderBookStream) update(status ingestionStatus) (bool, error) {
 	reset := o.lastLedger == 0
-	if status.StateInvalid || !status.HistoryConsistentWithState {
+	if status.StateInvalid {
 		log.WithField("status", status).Warn("ingestion state is invalid")
 		reset = true
+	} else if !status.HistoryConsistentWithState {
+		log.WithField("status", status).
+			Info("ingestion state not consistent with ingested history")
+		reset = true
 	} else if status.LastIngestedLedger < o.lastLedger {
 		log.WithField("status", status).
 			WithField("last_ledger", o.lastLedger).
@@ -124,8 +128,6 @@ func (o *OrderBookStream) update(status ingestionStatus) (bool, error) {
 
 		// wait until offers in horizon db is valid before populating order book graph
 		if status.StateInvalid || !status.HistoryConsistentWithState {
-			log.WithField("status", status).
-				Info("waiting for ingestion to update offers table")
 			return true, nil
 		}