diff --git a/pdf_agents/agents.py b/pdf_agents/agents.py
index 9019644..c112512 100644
--- a/pdf_agents/agents.py
+++ b/pdf_agents/agents.py
@@ -349,6 +349,7 @@ def close_and_restart(self, *, clear_tell_cache=False, retell_all=False, reason=
         """
         self.stop(reason=f"Close and Restart: {reason}")
         self.kafka_consumer.closed = False
+        self._compose_descriptor_bundles = dict()
         if clear_tell_cache:
             self.tell_cache = list()
         elif retell_all: