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

add logging for all apply actions, instead of in case of error(s)

Browse Source
This commit is contained in:
Yaroshevich, Denis
2021-03-12 15:00:24 +03:00
parent 2f90ce4756
commit 04a9b2b9b8
1 changed files with 20 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files
octodns/provider/gcore.py
+20 -29
View File
@@ -179,39 +179,30 @@ class GCoreProvider(BaseProvider):
_params_for_AAAA = _params_for_single
def _apply_create(self, change):
try:
new = change.new
rrset_name = self._build_rrset_name(new)
data = getattr(self, "_params_for_{}".format(new._type))(new)
self._client.record_create(
new.zone.name[:-1], rrset_name, new._type, data
)
except:
self.log.exception("failed to create RR: %s", change)
rai
self.log.info("creating: %s", change)
new = change.new
rrset_name = self._build_rrset_name(new)
data = getattr(self, "_params_for_{}".format(new._type))(new)
self._client.record_create(
new.zone.name[:-1], rrset_name, new._type, data
)
def _apply_update(self, change):
try:
new = change.new
rrset_name = self._build_rrset_name(new)
data = getattr(self, "_params_for_{}".format(new._type))(new)
self._client.record_update(
new.zone.name[:-1], rrset_name, new._type, data
)
except:
self.log.exception("failed to update RR: %s", change)
raise
self.log.info("updating: %s", change)
new = change.new
rrset_name = self._build_rrset_name(new)
data = getattr(self, "_params_for_{}".format(new._type))(new)
self._client.record_update(
new.zone.name[:-1], rrset_name, new._type, data
)
def _apply_delete(self, change):
try:
existing = change.existing
rrset_name = self._build_rrset_name(existing)
self._client.record_delete(
existing.zone.name[:-1], rrset_name, existing._type
)
except:
self.log.exception("failed to delete RR: %s", change)
raise
self.log.info("deleting: %s", change)
existing = change.existing
rrset_name = self._build_rrset_name(existing)
self._client.record_delete(
existing.zone.name[:-1], rrset_name, existing._type
)
def _apply(self, plan):
desired = plan.desired