def run()

in src/es_pii_tool/redacters/index.py [0:0]

• 24 lines of code
• 5 McCabe index (conditional complexity)

    def run(self):
        """Do the actual run"""
        if self.task.finished():
            self.success = True
            return
        # Log task start time
        self.task.begin()
        self.run_query()
        if self.task.completed:
            self.success = True
            return
        self.verify_fields()
        if self.task.completed:
            self.success = True
            return
        self.get_phase()
        if self.data.phase in ('cold', 'frozen'):
            self.snapshot_redact()
        else:
            self.normal_redact()
        # If we have reached this point, we've succeeded.
        self.counter += 1
        msg = f'Index {self.counter} of {self.task.job.total} processed...'
        logger.info(msg)
        self.task.add_log(msg)
        self.task.end(completed=True, logmsg='DONE')
        self.success = True