diff --git a/shared/workspaces/alembic/versions/08090cb7acc4_add_mark4_observation_ingestion_workflow.py b/shared/workspaces/alembic/versions/08090cb7acc4_add_mark4_observation_ingestion_workflow.py
index 45bde4289eb30f986b40418d753c71cdf728ed14..046b2a69b8eaf462191bf8e9e09cc12b14ad9f9b 100644
--- a/shared/workspaces/alembic/versions/08090cb7acc4_add_mark4_observation_ingestion_workflow.py
+++ b/shared/workspaces/alembic/versions/08090cb7acc4_add_mark4_observation_ingestion_workflow.py
@@ -63,7 +63,12 @@ for FILE in *; do
 
     FULLPATH=$(/bin/readlink -f $FILE)
     NGASCMD="${NGASHOST}ARCHIVE?filename=file://${FULLPATH}"
-    /bin/curl $NGASCMD
+
+    INGESTOUT=$(/bin/curl $NGASCMD)
+    if echo $INGESTOUT | grep -i "error"; then
+        echo "Failed to ingest ${FILE}"
+        exit 1
+    fi
 done"""
 
 def upgrade():