changing behaviour upon lack of uuid

agate/agate/queue_reading/ingestion_updater.py

@@ -16,11 +16,8 @@ def update(cls, data: dict, stage: str):
         """
         Use a dictionary to update items in the database
         """
-        try:
-            uuid = data["uuid"]
-        except KeyError:
-            logger.critical("no uuid")
-            return
+        uuid = data["uuid"]
+
         cls._manipulate_data(data, stage)
         cls._update_item(uuid, data)
 

agate/agate/queue_reading/queue_reader.py

@@ -65,7 +65,12 @@ def _update_item_from_message(self, message, stage: str):
         except json.decoder.JSONDecodeError:
             logger.critical(f"{stage}: not a valid json message: {message.body}")
             return
-        IngestionUpdater.update(data, stage)
+
+        if "uuid" in data:
+            # This message prompts updates to an injection attempt
+            IngestionUpdater.update(data, stage)
+        else:
+            logger.warning(f"{stage}: message did not refer to a uuid: {message.body}")
 
     def _update_lists(self, message):
         """