From 95d9ffc221917e592ec169fb05124f2bd29a2ed3 Mon Sep 17 00:00:00 2001 From: Ross McFarland Date: Thu, 3 Dec 2020 18:12:16 -0800 Subject: [PATCH] Tell the processor when it's being called in a target context --- octodns/processors/filters.py | 4 ++-- octodns/provider/base.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/octodns/processors/filters.py b/octodns/processors/filters.py index d483ab7..09613d3 100644 --- a/octodns/processors/filters.py +++ b/octodns/processors/filters.py @@ -14,7 +14,7 @@ class TypeAllowlistFilter(BaseProcessor): super(TypeAllowlistFilter, self).__init__(name) self.allowlist = allowlist - def process(self, zone): + def process(self, zone, target=False): ret = self._create_zone(zone) for record in zone.records: if record._type in self.allowlist: @@ -29,7 +29,7 @@ class TypeRejectlistFilter(BaseProcessor): super(TypeRejectlistFilter, self).__init__(name) self.rejectlist = rejectlist - def process(self, zone): + def process(self, zone, target=False): ret = self._create_zone(zone) for record in zone.records: if record._type not in self.rejectlist: diff --git a/octodns/provider/base.py b/octodns/provider/base.py index 2a4ab11..137b664 100644 --- a/octodns/provider/base.py +++ b/octodns/provider/base.py @@ -56,7 +56,7 @@ class BaseProvider(BaseSource): 'exists', self.id) for processor in processors: - existing = processor.process(existing) + existing = processor.process(existing, target=True) # compute the changes at the zone/record level changes = existing.changes(desired, self)