Protect against missing GROUPID header.

lsst-dm · Sep 6, 2024 · 27b6e4b · 27b6e4b
1 parent 060181b
commit 27b6e4b
Showing 1 changed file with 8 additions and 7 deletions.
diff --git a/src/ingest.py b/src/ingest.py
@@ -174,14 +174,15 @@ def record_groups(resources: list[ResourcePath]) -> None:
                         instrument = "LSSTCam"
                     case "latiss":
                         instrument = "LATISS"
-                groupid = header["GROUPID"]
-                snap_number = int(header["CURINDEX"]) - 1
-                detector = header["RAFTBAY"] + "_" + header["CCDSLOT"]
-                key = f"GROUP:{instrument}:{groupid}:{snap_number}:{detector}"
-                pipe.set(key, str(res))
-                pipe.expire(key, group_lifetime)
+                if "GROUPID" in header:
+                    groupid = header["GROUPID"]
+                    snap_number = int(header["CURINDEX"]) - 1
+                    detector = header["RAFTBAY"] + "_" + header["CCDSLOT"]
+                    key = f"GROUP:{instrument}:{groupid}:{snap_number}:{detector}"
+                    pipe.set(key, str(res))
+                    pipe.expire(key, group_lifetime)
             except Exception:
-                logger.exception("Error reading group for %s", res)
+                logger.exception("Error reading snap/detector for %s", res)
         pipe.execute()