Filter out not applied operations (#32)

dipdup-io · Apr 23, 2021 · 579e95e · 579e95e
1 parent d30bee8
commit 579e95e
Showing 1 changed file with 1 addition and 2 deletions.
diff --git 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():