From 7f88d89849095a8dcc1fb7ba8d289ce5c113424c Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Tue, 8 Jul 2025 11:35:18 -0300 Subject: [PATCH] SIENTIAPDE-1110 Enhance logging in Ingestor class for subscription management - Added debug logging for subscribing to new slots, resubscribing to modified slots, and unsubscribing from removed slots in the Ingestor class. --- ingestor/ingestor.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/ingestor/ingestor.py b/ingestor/ingestor.py index 681e64d..572d900 100644 --- a/ingestor/ingestor.py +++ b/ingestor/ingestor.py @@ -260,15 +260,18 @@ class Ingestor: for slot, config in new_managed_tags.items(): if slot not in old_managed_tags: + self.logger.debug("Subscribing to new slot %s", slot) self.ingestor_manager.subscribe_to_tags({slot: config}) continue if config != old_managed_tags[slot]: + self.logger.debug("Resubscribing to slot %s", slot) self.ingestor_manager.unsubscribe_slot(slot) self.ingestor_manager.subscribe_to_tags({slot: config}) for slot in old_managed_tags.keys(): if slot not in new_managed_tags: + self.logger.debug("Unsubscribing from slot %s", slot) self.ingestor_manager.unsubscribe_slot(slot) # Ensure the gauge is updated after any potential changes here