From 08053b039c45d80f03e21076955dc6257724ca40 Mon Sep 17 00:00:00 2001 From: Abdul Rabbani Date: Thu, 31 Mar 2022 14:11:57 -0400 Subject: [PATCH] Update known_gaps table name --- statediff/indexer/database/sql/postgres/database.go | 4 ++-- statediff/indexer/models/models.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) 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"`