Added check to report if NGAS ingestion failed

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():