Browse Source

Update Manager to use MetaProcessor rather than special case of adding a meta record

pull/1061/head
Ross McFarland 2 years ago
parent
commit
0ad0c6be71
No known key found for this signature in database GPG Key ID: 943B179E15D3B22A
1 changed files with 14 additions and 12 deletions
  1. +14
    -12
      octodns/manager.py

+ 14
- 12
octodns/manager.py View File

@ -14,10 +14,10 @@ from sys import stdout
from . import __VERSION__ from . import __VERSION__
from .idna import IdnaDict, idna_decode, idna_encode from .idna import IdnaDict, idna_decode, idna_encode
from .processor.arpa import AutoArpa from .processor.arpa import AutoArpa
from .processor.meta import MetaProcessor
from .provider.base import BaseProvider from .provider.base import BaseProvider
from .provider.plan import Plan from .provider.plan import Plan
from .provider.yaml import SplitYamlProvider, YamlProvider from .provider.yaml import SplitYamlProvider, YamlProvider
from .record import Record
from .yaml import safe_load from .yaml import safe_load
from .zone import Zone from .zone import Zone
@ -137,6 +137,19 @@ class Manager(object):
auto_arpa.name auto_arpa.name
] + self.global_post_processors ] + self.global_post_processors
if self.include_meta:
self.log.info(
'__init__: adding meta to processors and providers, appending it to global_post_processors list'
)
meta = MetaProcessor(
'meta',
record_name='octodns-meta',
include_time=False,
include_provider=True,
)
self.processors[meta.id] = meta
self.global_post_processors.append(meta.id)
plan_outputs_config = manager_config.get( plan_outputs_config = manager_config.get(
'plan_outputs', 'plan_outputs',
{ {
@ -440,17 +453,6 @@ class Manager(object):
plans = [] plans = []
for target in targets: for target in targets:
if self.include_meta:
meta = Record.new(
zone,
'octodns-meta',
{
'type': 'TXT',
'ttl': 60,
'value': f'provider={target.id}',
},
)
zone.add_record(meta, replace=True)
try: try:
plan = target.plan(zone, processors=processors) plan = target.plan(zone, processors=processors)
except TypeError as e: except TypeError as e:


Loading…
Cancel
Save