From 579e95eac5348ea68a050c756288e5d47f88355d Mon Sep 17 00:00:00 2001 From: Lev Gorodetskiy Date: Fri, 23 Apr 2021 13:32:02 +0300 Subject: [PATCH] Filter out not applied operations (#32) --- src/dipdup/datasources/tzkt/datasource.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/dipdup/datasources/tzkt/datasource.py b/src/dipdup/datasources/tzkt/datasource.py index 4d1679c96..f754cd1c4 100644 --- a/src/dipdup/datasources/tzkt/datasource.py +++ b/src/dipdup/datasources/tzkt/datasource.py @@ -162,6 +162,7 @@ async def _fetch_operations(self, address: str, offset: int, first_level: int, l "level.gt": first_level, "level.le": last_level, "select": ','.join(OPERATION_FIELDS), + "status": "applied", }, ) as resp: operations = await resp.json() @@ -262,8 +263,6 @@ async def on_operation_message( operation = self.convert_operation(operation_json) if operation.type != 'transaction': continue - if operation.status != 'applied': - continue await self._caches[address].add(operation) async with in_transaction():