From 21826dd308165fd87f07010694e7d090e57a643c Mon Sep 17 00:00:00 2001 From: Luke Van Seters Date: Thu, 23 Dec 2021 10:09:32 -0500 Subject: [PATCH] Pass error through from trace to liquidation --- mev_inspect/aave_liquidations.py | 1 + mev_inspect/compound_liquidations.py | 2 ++ mev_inspect/inspector.py | 3 ++- mev_inspect/models/liquidations.py | 1 + mev_inspect/schemas/liquidations.py | 1 + 5 files changed, 7 insertions(+), 1 deletion(-) diff --git a/mev_inspect/aave_liquidations.py b/mev_inspect/aave_liquidations.py index cadb6fc..49833ea 100644 --- a/mev_inspect/aave_liquidations.py +++ b/mev_inspect/aave_liquidations.py @@ -70,6 +70,7 @@ def get_aave_liquidations( transaction_hash=trace.transaction_hash, trace_address=trace.trace_address, block_number=trace.block_number, + error=trace.error, ) ) diff --git a/mev_inspect/compound_liquidations.py b/mev_inspect/compound_liquidations.py index df45420..912cb64 100644 --- a/mev_inspect/compound_liquidations.py +++ b/mev_inspect/compound_liquidations.py @@ -48,6 +48,7 @@ def get_compound_liquidations( transaction_hash=trace.transaction_hash, trace_address=trace.trace_address, block_number=trace.block_number, + error=trace.error, ) ) elif ( @@ -65,6 +66,7 @@ def get_compound_liquidations( transaction_hash=trace.transaction_hash, trace_address=trace.trace_address, block_number=trace.block_number, + error=trace.error, ) ) return liquidations diff --git a/mev_inspect/inspector.py b/mev_inspect/inspector.py index 0678464..7a53908 100644 --- a/mev_inspect/inspector.py +++ b/mev_inspect/inspector.py @@ -75,8 +75,9 @@ class MEVInspector: except CancelledError: logger.info("Requested to exit, cleaning up...") except Exception as e: - logger.error(f"Existed due to {type(e)}") + logger.error(f"Exited due to {type(e)}") traceback.print_exc() + raise async def safe_inspect_many_blocks( self, diff --git a/mev_inspect/models/liquidations.py b/mev_inspect/models/liquidations.py index 8cd2338..afce0ab 100644 --- a/mev_inspect/models/liquidations.py +++ b/mev_inspect/models/liquidations.py @@ -16,3 +16,4 @@ class LiquidationModel(Base): transaction_hash = Column(String, primary_key=True) trace_address = Column(ARRAY(Integer), primary_key=True) block_number = Column(Numeric, nullable=False) + error = Column(String, nullable=True) diff --git a/mev_inspect/schemas/liquidations.py b/mev_inspect/schemas/liquidations.py index 5f49cc3..8ef4faa 100644 --- a/mev_inspect/schemas/liquidations.py +++ b/mev_inspect/schemas/liquidations.py @@ -16,3 +16,4 @@ class Liquidation(BaseModel): transaction_hash: str trace_address: List[int] block_number: str + error: Optional[str]