diff --git a/statediff/indexer/database/sql/postgres/database.go b/statediff/indexer/database/sql/postgres/database.go index 5b5a44d4c..ec5680c10 100644 --- a/statediff/indexer/database/sql/postgres/database.go +++ b/statediff/indexer/database/sql/postgres/database.go @@ -110,7 +110,7 @@ func (db *DB) InsertKnownGapsStm() string { // InsertKnownGapsStm satisfies the sql.Statements interface func (db *DB) InsertKnownGapsStm() string { - return `INSERT INTO eth.known_gaps (starting_block_number, ending_block_number, checked_out, processing_key) VALUES ($1, $2, $3, $4) + return `INSERT INTO eth_meta.known_gaps (starting_block_number, ending_block_number, checked_out, processing_key) VALUES ($1, $2, $3, $4) ON CONFLICT (starting_block_number) DO UPDATE SET (ending_block_number, processing_key) = ($2, $4) - WHERE eth.known_gaps.ending_block_number <= $2` + WHERE eth_meta.known_gaps.ending_block_number <= $2` } diff --git a/statediff/indexer/models/models.go b/statediff/indexer/models/models.go index d0ad13a59..b4386fdf8 100644 --- a/statediff/indexer/models/models.go +++ b/statediff/indexer/models/models.go @@ -166,7 +166,7 @@ type KnownGapsModel struct { ProcessingKey int64 `db:"processing_key"` } -// KnownGaps is the data structure for eth.known_gaps +// KnownGaps is the data structure for eth_meta.known_gaps type KnownGapsModel struct { StartingBlockNumber string `db:"starting_block_number"` EndingBlockNumber string `db:"ending_block_number"`