isort

crawlers/mooncrawl/mooncrawl/generic_crawler/cli.py

@@ -11,8 +11,8 @@ from web3.middleware import geth_poa_middleware
 from mooncrawl.data import AvailableBlockchainType  # type: ignore
 
 from ..blockchain import connect
-from .base import crawl, get_checkpoint, populate_with_events
 from ..settings import NB_CONTROLLER_ACCESS_ID
+from .base import crawl, get_checkpoint, populate_with_events
 
 logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)

crawlers/mooncrawl/mooncrawl/moonworm_crawler/cli.py

@@ -10,7 +10,6 @@ from web3.middleware import geth_poa_middleware
 from ..blockchain import AvailableBlockchainType
 from ..settings import MOONSTREAM_MOONWORM_TASKS_JOURNAL, NB_CONTROLLER_ACCESS_ID
 from .continuous_crawler import _retry_connect_web3, continuous_crawler
-from .historical_crawler import historical_crawler
 from .crawler import (
     SubscriptionTypes,
     blockchain_type_to_subscription_type,
@@ -19,6 +18,7 @@ from .crawler import (
     make_function_call_crawl_jobs,
 )
 from .db import get_first_labeled_block_number, get_last_labeled_block_number
+from .historical_crawler import historical_crawler
 
 logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)

crawlers/mooncrawl/mooncrawl/moonworm_crawler/continuous_crawler.py

@@ -17,6 +17,7 @@ from ..data import AvailableBlockchainType
 from .crawler import (
     EventCrawlJob,
     FunctionCallCrawlJob,
+    _retry_connect_web3,
     blockchain_type_to_subscription_type,
     get_crawl_job_entries,
     heartbeat,
@@ -24,7 +25,6 @@ from .crawler import (
     make_function_call_crawl_jobs,
     merge_event_crawl_jobs,
     merge_function_call_crawl_jobs,
-    _retry_connect_web3,
 )
 from .db import add_events_to_session, add_function_calls_to_session, commit_session
 from .event_crawler import _crawl_events

crawlers/mooncrawl/mooncrawl/moonworm_crawler/db.py

@@ -1,7 +1,6 @@
 import logging
 from typing import Any, Dict, List, Optional, Union
 
-
 from moonstreamdb.models import Base
 from moonworm.crawler.function_call_crawler import ContractFunctionCall  # type: ignore
 from sqlalchemy.orm import Session

crawlers/mooncrawl/mooncrawl/moonworm_crawler/historical_crawler.py

@@ -1,5 +1,4 @@
 import logging
-import logging
 import time
 from typing import Dict, List, Optional, Tuple
 from uuid import UUID
@@ -12,16 +11,11 @@ from sqlalchemy.orm.session import Session
 from web3 import Web3
 
 from ..data import AvailableBlockchainType
-from .crawler import (
-    EventCrawlJob,
-    FunctionCallCrawlJob,
-    _retry_connect_web3,
-)
+from .crawler import EventCrawlJob, FunctionCallCrawlJob, _retry_connect_web3
 from .db import add_events_to_session, add_function_calls_to_session, commit_session
 from .event_crawler import _crawl_events
 from .function_call_crawler import _crawl_functions
 
-
 logging.basicConfig(level=logging.INFO)
 logger = logging.getLogger(__name__)