diff --git a/trustgraph-flow/trustgraph/librarian/service.py b/trustgraph-flow/trustgraph/librarian/service.py
index c24a5fe8..b41f177e 100755
--- a/trustgraph-flow/trustgraph/librarian/service.py
+++ b/trustgraph-flow/trustgraph/librarian/service.py
@@ -418,14 +418,15 @@ class Processor(AsyncProcessor):
             self.pubsub, q, schema=schema
         )
 
-        await pub.start()
+        try:
+            await pub.start()
 
-        # FIXME: Time wait kludge?
-        await asyncio.sleep(1)
+            # FIXME: Time wait kludge?
+            await asyncio.sleep(1)
 
-        await pub.send(None, doc)
-
-        await pub.stop()
+            await pub.send(None, doc)
+        finally:
+            await pub.stop()
 
         logger.debug("Document submitted")