Skip to content

Commit

Permalink
fix: addressed pylint issues
Browse files Browse the repository at this point in the history
  • Loading branch information
frolvanya committed May 29, 2024
1 parent f10b3f1 commit 4707ada
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 7 deletions.
8 changes: 2 additions & 6 deletions src/near_lake_framework/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down Expand Up @@ -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 = []
Expand All @@ -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,
)
Expand Down
1 change: 0 additions & 1 deletion src/near_lake_framework/s3_fetchers.py
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down

0 comments on commit 4707ada

Please sign in to comment.