Skip to content

Commit 38edf01

Browse files
fix: rebase
1 parent bb3c5e8 commit 38edf01

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

bridgesync/backfill_tx_sender.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -171,7 +171,8 @@ func (b *BackfillTxnSender) getRecordsNeedingBackfillCount(ctx context.Context,
171171
dbCtx, cancel := context.WithTimeout(ctx, b.dbTimeout)
172172
defer cancel()
173173

174-
err := b.db.QueryRowContext(dbCtx, query, BridgeSourceBackwardLET, BridgeSourceForwardLET).Scan(&count)
174+
err := b.db.QueryRowContext(dbCtx, query,
175+
BridgeSourceRestoredBackwardLET, BridgeSourceForwardLET).Scan(&count)
175176
if err != nil {
176177
return 0, fmt.Errorf("failed to count records needing backfill: %w", err)
177178
}
@@ -196,7 +197,8 @@ func (b *BackfillTxnSender) getRecordsNeedingBackfill(
196197

197198
dbCtx, cancel := context.WithTimeout(ctx, b.dbTimeout)
198199
defer cancel()
199-
rows, err := b.db.QueryContext(dbCtx, query, BridgeSourceBackwardLET, BridgeSourceForwardLET, limit)
200+
rows, err := b.db.QueryContext(dbCtx, query,
201+
BridgeSourceRestoredBackwardLET, BridgeSourceForwardLET, limit)
200202
if err != nil {
201203
return nil, fmt.Errorf("failed to query records needing backfill: %w", err)
202204
}

0 commit comments

Comments
 (0)