diff --git a/ingestion/tests/integration/sources/database/delta_lake/test_deltalake_storage.py b/ingestion/tests/integration/sources/database/delta_lake/test_deltalake_storage.py
index 3c74265f703e..0663849c044f 100644
--- a/ingestion/tests/integration/sources/database/delta_lake/test_deltalake_storage.py
+++ b/ingestion/tests/integration/sources/database/delta_lake/test_deltalake_storage.py
@@ -136,6 +136,7 @@ def ingest(metadata, service, create_data):
 
     ingestion = MetadataWorkflow.create(workflow_config)
     ingestion.execute()
+    ingestion.raise_from_status()
     return