From 3ca3c2d530d70f652e1bdc89757be81f2850ba94 Mon Sep 17 00:00:00 2001 From: Yhtyyar Sahatov Date: Mon, 4 Apr 2022 17:44:32 +0300 Subject: [PATCH] checkpoint uses transactions table --- datasets/nfts/nfts/datastore.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/datasets/nfts/nfts/datastore.py b/datasets/nfts/nfts/datastore.py index 5a924a52..d8861908 100644 --- a/datasets/nfts/nfts/datastore.py +++ b/datasets/nfts/nfts/datastore.py @@ -386,7 +386,7 @@ def get_last_saved_block(conn: sqlite3.Connection, blockchain_type: str) -> int: """ cur = conn.cursor() - query = f"SELECT MAX(blockNumber) FROM transfers WHERE blockchain_type = '{blockchain_type}'" + query = f"SELECT MAX(blockNumber) FROM transactions WHERE blockchain_type = '{blockchain_type}'" cur.execute(query) if cur.fetchone()[0] is None: