in src/es_pii_tool/redacters/index.py [0:0]
def normal_redact(self):
"""Redact data from a normal (not searchable-snapshot) index"""
msg = 'Initiating redaction of data from writeable index...'
logger.info(msg)
self.task.add_log(msg)
# As the redact_from_index function doesn't track dry-run, we have to do it
if not self.task.job.dry_run:
msg = f'Redacting data from {self.index}'
logger.info(msg)
self.task.add_log(msg)
try:
api.redact_from_index(
self.task.job.client, self.index, self.task.job.config
)
except (MissingIndex, BadClientResult) as exc:
kwargs = {'completed': False, 'errors': True, 'logmsg': 'replaceme'}
self.end_in_failure(
exc, reraise=False, func=self.task.end, kwargs=kwargs
)
else:
msg = f'DRY-RUN: Will not redact data from {self.index}'
logger.info(msg)
self.task.add_log(msg)