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]