diff --git a/alembic/versions/4b9d289f2d74_add_error_column_to_liquidations.py b/alembic/versions/4b9d289f2d74_add_error_column_to_liquidations.py
new file mode 100644
index 0000000..f3aecd7
--- /dev/null
+++ b/alembic/versions/4b9d289f2d74_add_error_column_to_liquidations.py
@@ -0,0 +1,23 @@
+"""Add error column to liquidations
+
+Revision ID: 4b9d289f2d74
+Revises: 99d376cb93cc
+Create Date: 2021-12-23 14:54:28.406159
+
+"""
+import sqlalchemy as sa
+from alembic import op
+
+# revision identifiers, used by Alembic.
+revision = "4b9d289f2d74"
+down_revision = "99d376cb93cc"
+branch_labels = None
+depends_on = None
+
+
+def upgrade():
+    op.add_column("liquidations", sa.Column("error", sa.String(256), nullable=True))
+
+
+def downgrade():
+    op.drop_column("liquidations", "error")
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]