enabling more error catching

ingestor/app.py

@@ -80,18 +80,20 @@ queue_name = os.environ['REDIS_PREPROCESS_MD_QUEUE_KEY']
 
 @application.route('/', methods=['POST'])
 def ingest():
-    request.get_data()
-    browse_report = parse_browse_report(request.data)
-    logger.debug(browse_report)
-    if isinstance(browse_report, str):
-        queue_content = browse_report
-        filename = queue_content
-    else:
-        queue_content = json.dumps(
-            browse_report, default=converter
-        )
-        filename = browse_name(browse_report)
+
     try:
+        request.get_data()
+        browse_report = parse_browse_report(request.data)
+        logger.debug(browse_report)
+        if isinstance(browse_report, str):
+            queue_content = browse_report
+            filename = queue_content
+        else:
+            queue_content = json.dumps(
+                browse_report, default=converter
+            )
+            filename = browse_name(browse_report)
+    
         client.lpush(queue_name, queue_content)
         
         save_endpoint_report(filename, request.data, True)

ingestor/filedaemon.py

@@ -84,17 +84,18 @@ class EventHandler(pyinotify.ProcessEvent):
     def process_IN_CLOSE_WRITE(self, event):
         logger.info(f'Parsing browse file: {event.pathname}')
 
-        with open(event.pathname) as f:
-            browse_report = parse_browse_report(f)
-        logger.debug(browse_report)
-        if isinstance(browse_report, str):
-            queue_content = browse_report
-
-        else:
-            queue_content = json.dumps(
-                browse_report, default=converter
-            )
-        try:  
+        try: 
+            with open(event.pathname) as f:
+                browse_report = parse_browse_report(f)
+            logger.debug(browse_report)
+            if isinstance(browse_report, str):
+                queue_content = browse_report
+
+            else:
+                queue_content = json.dumps(
+                    browse_report, default=converter
+                )
+         
             client.lpush(queue_name, queue_content)
             
             save_mount_report(event.pathname, True)