Only attempt to write if any arbitrages

This commit is contained in:
Luke Van Seters 2021-08-06 13:45:05 -04:00
parent 6c727fb1f6
commit 28081de807

View File

@ -49,15 +49,16 @@ def write_arbitrages(
} }
) )
db_session.bulk_save_objects(arbitrage_models) if len(arbitrage_models) > 0:
db_session.execute( db_session.bulk_save_objects(arbitrage_models)
""" db_session.execute(
INSERT INTO arbitrage_swaps """
(arbitrage_id, swap_transaction_hash, swap_trace_address) INSERT INTO arbitrage_swaps
VALUES (arbitrage_id, swap_transaction_hash, swap_trace_address)
(:arbitrage_id, :swap_transaction_hash, :swap_trace_address) VALUES
""", (:arbitrage_id, :swap_transaction_hash, :swap_trace_address)
params=swap_arbitrage_ids, """,
) params=swap_arbitrage_ids,
)
db_session.commit() db_session.commit()