From a17a7ce77a7f177fcb121249caf1fdff19cc274d Mon Sep 17 00:00:00 2001 From: Yhtyyar Sahatov Date: Fri, 9 Sep 2022 01:04:51 +0300 Subject: [PATCH] small fixes to dataset materialize --- datasets/nfts/nfts/materialize.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/datasets/nfts/nfts/materialize.py b/datasets/nfts/nfts/materialize.py index 7a13827f..1f3a6ab2 100644 --- a/datasets/nfts/nfts/materialize.py +++ b/datasets/nfts/nfts/materialize.py @@ -34,7 +34,7 @@ from .datastore import insert_events, insert_transactions logging.basicConfig(level=logging.INFO) logger = logging.getLogger(__name__) -ERC721_LABEL = "erc721" +ERC721_LABEL = "erc721-v2" ERC20_LABEL = "test-erc20" @@ -194,7 +194,7 @@ def crawl_erc721_labels( def crawl_with_threads(ranges: List[Tuple[int, int]]): futures: Dict[Future, Tuple[int, int]] = {} - with ThreadPoolExecutor(max_workers=20) as executor: + with ThreadPoolExecutor(max_workers=30) as executor: for from_block, to_block in ranges: future = executor.submit(_crawl, from_block, to_block) futures[future] = (from_block, to_block)