merge leftovers

pyproject.toml

@@ -1,7 +1,7 @@
 [project]
 name = "dipdup"
 description = "Modular framework for creating selective indexers and featureful backends for dapps"
-version = "7.2.1"
+version = "7.2.2"
 license = { text = "MIT" }
 authors = [
     { name = "Lev Gorodetskii", email = "[email protected]" },
@@ -70,6 +70,7 @@ dependencies = [
     "sentry-sdk~=1.29",
     "setuptools>=68.1.2",
     "sqlparse~=0.4",
+    "strict-rfc3339~=0.7",
     "survey~=4.4",
     "tabulate~=0.9",
     "web3~=6.2",

src/dipdup/datasources/evm_subsquid.py

@@ -14,14 +14,13 @@
 from dipdup.datasources import Datasource
 from dipdup.datasources import IndexDatasource
 from dipdup.exceptions import DatasourceError
-from dipdup.models.evm_subsquid import FieldSelection, LogFieldSelection
+from dipdup.models.evm_subsquid import FieldSelection
 from dipdup.models.evm_subsquid import LogRequest
 from dipdup.models.evm_subsquid import Query
 from dipdup.models.evm_subsquid import SubsquidEventData
 from dipdup.models.evm_subsquid import SubsquidTransactionData
 from dipdup.models.evm_subsquid import TransactionRequest
 
-
 POLL_INTERVAL = 1
 LOG_FIELDS: FieldSelection = {
     'log': {

src/dipdup/indexes/evm_subsquid_events/index.py

@@ -119,7 +119,7 @@ async def _synchronize(self, sync_level: int) -> None:
 
                 batch_last_level = min(batch_first_level + NODE_BATCH_SIZE, sync_level)
                 level_logs_task = asyncio.create_task(
-                    self.random_node.get_logs(
+                    self.get_random_node().get_logs(
                         {
                             'fromBlock': hex(batch_first_level),
                             'toBlock': hex(batch_last_level),