Task base class for Spotify's Luigi framework to force a task to clean-up its outputs, ie reset and re-run a task. Credits to https://github.com/spotify/luigi/issues/595#issuecomment-194323344

tasks.py

import luigi


class ForceableTask(luigi.Task):

    force = luigi.BoolParameter(significant=False, default=False)

    def __init__(self, *args, **kwargs):
        super().__init__(*args, **kwargs)
        # To force execution, we just remove all outputs before `complete()` is called
        if self.force is True:
            outputs = luigi.task.flatten(self.output())
            for out in outputs:
                if out.exists():
                    os.remove(self.output().path)

From: spotify/luigi#595 (comment)