Descriptors in event stream

bluesky · Feb 1, 2024 · 5c34a7b · 5c34a7b
1 parent be534ac
commit 5c34a7b
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/databroker/mongo_normalized.py b/databroker/mongo_normalized.py
@@ -276,18 +276,19 @@ def metadata(self):
     async def update_metadata(self, metadata=None, specs=None):
         if("start" not in metadata):
              raise NotImplementedError('update_metadata method not implemented')
-        elif(specs is not None):
+        elif(specs is None):
             raise NotImplementedError('Updating of specs is not yet supported.')
         start = metadata["start"]
-        # stop = metadata["stop"]
+        stop = metadata["stop"] if "stop" in metadata else None
         try:
             schema_validators[DocumentNames.start].validate(start)
-            # schema_validators[DocumentNames.stop].validate(stop)
+            if (stop is not None):
+                schema_validators[DocumentNames.stop].validate(stop)
         except ValidationError as err:
             raise
         # Update start
         self._serializer.update("start", metadata["start"])
-        # self._serializer.update("stop", metadata["stop"])
+        self._serializer.update("stop", metadata["stop"])
 
     @property
     def filler(self):