From 6ed475fc4be51db0cd45ac50ed45a6614886253d Mon Sep 17 00:00:00 2001 From: Ross McFarland Date: Mon, 15 Jan 2024 15:20:10 -0800 Subject: [PATCH] Log per zone processors along with sources and targets, clean up formatting --- octodns/manager.py | 21 ++++++++++----------- 1 file changed, 10 insertions(+), 11 deletions(-) diff --git a/octodns/manager.py b/octodns/manager.py index 7529a45..7b26f83 100644 --- a/octodns/manager.py +++ b/octodns/manager.py @@ -517,7 +517,7 @@ class Manager(object): ]: return None - self.log.info('sync: sources=%s', sources) + self.log.info('sync: sources=%s', sources) try: # rather than using a list comprehension, we break this loop @@ -562,9 +562,7 @@ class Manager(object): zone_name, ) continue - self.log.info( - 'sync: adding dynamic zone=%s', zone_name - ) + self.log.info('sync: adding dynamic zone=%s', zone_name) zones[zone_name] = config # remove the dynamic config element so we don't try and populate it @@ -659,7 +657,12 @@ class Manager(object): f'Zone {decoded_zone_name} is missing targets' ) - processors = config.get('processors', []) + processors = ( + self.global_processors + + config.get('processors', []) + + self.global_post_processors + ) + self.log.info('sync: processors=%s', processors) if not sources: self.log.info('sync: no eligible sources, skipping') @@ -675,15 +678,11 @@ class Manager(object): self.log.info('sync: no eligible targets, skipping') continue - self.log.info('sync: targets=%s', targets) + self.log.info('sync: targets=%s', targets) try: collected = [] - for processor in ( - self.global_processors - + processors - + self.global_post_processors - ): + for processor in processors: collected.append(self.processors[processor]) processors = collected except KeyError: