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

Merge branch 'main' into record-rdata-coverage

Browse Source
This commit is contained in:
Ross McFarland
2024-01-24 08:04:49 -08:00
committed by GitHub
parent b148a4c716 27de4c7e28
commit 90698eef93
1 changed files with 10 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
octodns/manager.py
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: