

def execute(self, **kwargs):
    self.update_progress(0)
    self.update_progress(0.99)
    raise RuntimeError('Woot!')

dataset/ETHPy150Open openstack/taskflow/taskflow/tests/utils.py FailingTask.execute/original