feat: filter 0 value transfers from treasury export (#702)

yearn · Apr 8, 2024 · 1739e85 · 1739e85
1 parent a07e5bd
commit 1739e85
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/scripts/exporters/treasury_transactions.py b/scripts/exporters/treasury_transactions.py
@@ -53,9 +53,11 @@ def main() -> NoReturn:
 
 @a_sync(default='sync')
 async def load_new_txs(start_block: Block, end_block: Block) -> int:
-    futs = []
-    async for entry in treasury.ledger._get_and_yield(start_block, end_block):
-        futs.append(asyncio.create_task(insert_treasury_tx(entry)))
+    futs = [
+        asyncio.create_task(insert_treasury_tx(entry))
+        async for entry in treasury.ledger._get_and_yield(start_block, end_block)
+        if entry.value
+    ]
     return sum(await tqdm_asyncio.gather(*futs, desc="Insert Txs to Postgres"))