From 4707ada5937945608dba5df712866b29b85a505d Mon Sep 17 00:00:00 2001 From: Ivan Frolov Date: Wed, 29 May 2024 10:22:33 -0400 Subject: [PATCH] fix: addressed pylint issues --- src/near_lake_framework/__init__.py | 8 ++------ src/near_lake_framework/s3_fetchers.py | 1 - 2 files changed, 2 insertions(+), 7 deletions(-) diff --git a/src/near_lake_framework/__init__.py b/src/near_lake_framework/__init__.py index 79f6fdd..d870a2c 100644 --- a/src/near_lake_framework/__init__.py +++ b/src/near_lake_framework/__init__.py @@ -13,8 +13,6 @@ from near_lake_framework import s3_fetchers -from dataclasses import dataclass - # Configure logging logging.basicConfig( level=logging.INFO, format="%(asctime)s %(levelname)s %(name)s %(message)s" @@ -95,9 +93,7 @@ async def start(config: LakeConfig, streamer_messages_queue: asyncio.Queue): await asyncio.sleep(2) continue - logger.info( - "Received {} blocks from S3".format(len(block_heights_prefixes)) - ) + logger.info(f"Received {len(block_heights_prefixes)} blocks from S3") pending_block_heights = iter(block_heights_prefixes) streamer_messages_futures = [] @@ -121,7 +117,7 @@ async def start(config: LakeConfig, streamer_messages_queue: asyncio.Queue): != streamer_message.block.header.prev_hash ): logger.warning( - "`prev_hash` does not match, re-fetching the data from S3 in 200ms", + "`prev_hash` does not match, re-fetching the data from S3 in 200ms: %s != %s", last_processed_block_hash, streamer_message.block.header.prev_hash, ) diff --git a/src/near_lake_framework/s3_fetchers.py b/src/near_lake_framework/s3_fetchers.py index 0a9c2b8..27a520b 100644 --- a/src/near_lake_framework/s3_fetchers.py +++ b/src/near_lake_framework/s3_fetchers.py @@ -4,7 +4,6 @@ from botocore.exceptions import ClientError, EndpointConnectionError from near_lake_framework import near_primitives -from near_lake_framework.near_primitives import IndexerShard async def list_blocks(