From 37bf337553a0fbbb8e27130de351f1d5aed2e567 Mon Sep 17 00:00:00 2001 From: Yhtyyar Sahatov Date: Mon, 4 Apr 2022 17:42:55 +0300 Subject: [PATCH] fix checkpointing --- 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 59415a06..5a924a52 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(block_number) FROM transactions WHERE blockchain_type = '{blockchain_type}'" + query = f"SELECT MAX(blockNumber) FROM transfers WHERE blockchain_type = '{blockchain_type}'" cur.execute(query) if cur.fetchone()[0] is None: