Refresh cached schema on key miss.

lsst-dm · May 16, 2024 · b1b3ec4 · b1b3ec4
1 parent 24410ef
commit b1b3ec4
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/python/lsst/consdb/pqserver.py b/python/lsst/consdb/pqserver.py
@@ -530,7 +530,15 @@ def insert_flexible_metadata(
         value_dict = info["values"]
         for key, value in value_dict.items():
             if key not in schema:
-                raise BadValueException("key", key, list(schema.keys()))
+                # Refresh cached schema
+                schema = dict()
+                stmt = sqlalchemy.select(schema_table.c["key", "dtype", "doc", "unit", "ucd"])
+                with engine.connect() as conn:
+                    for row in conn.execute(stmt):
+                        schema[row[0]] = row[1:]
+                instrument_tables.flexible_metadata_schemas[instrument][obs_type] = schema
+                if key not in schema:
+                    raise BadValueException("key", key, list(schema.keys()))
 
             # check value against dtype
             dtype = schema[key][0]