mirror/github-octodns
1
0
Fork 0
mirror of https://github.com/github/octodns.git synced 2024-05-11 05:55:00 +00:00
Code Issues Releases Activity

Log per zone processors along with sources and targets, clean up formatting

Browse Source
This commit is contained in:
Ross McFarland
2024-01-15 15:20:10 -08:00
parent e1d2c43174
commit 6ed475fc4b
1 changed files with 10 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
octodns/manager.py
+10 -11
View File
@@ -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: