

def execute(self, **kwargs):
    self.update_progress(0.0)
    self.update_progress(1.0)
    return 5

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