Source code for acquisition.delete_step

from acquisition import AcquisitionStep


[docs]class AcquisitionDeleteStep(AcquisitionStep):

[docs]    def init(self):
        self.failure_policy = "delete"

[docs]    def process(self, xaf):
        res = xaf.delete_or_nothing()
        if res:
            self.info("%s deleted", xaf.filepath)
            return True
        else:
            self.warning("Can't delete %s", xaf.filepath)
            return False