subscribe fix

ingestor/ingestor.py

@@ -194,6 +194,10 @@ class Ingestor:
 
             self.ingestor_manager.drop_slot_leases(overleases)
 
+            for lease in overleases:
+                self.ingestor_manager.unsubscribe_slot(lease)
+                self.ingestor_manager.managed_tags.pop(lease)
+
     def update_ingestor_manager(self, old_managed_tags: Dict[str, Any]):
         """
         Updates the ingestor manager with the new managed tags.