

def all_tasks(self, skip_aborted=True):
    all_tasks = []
    all_tasks += getattr(self, 'tasks', [])
    task_groups = getattr(self, 'task_groups', [])
    all_tasks += [t for task_group in task_groups for t in task_group]
    if skip_aborted:
        all_tasks = [t for t in all_tasks if (not is_aborted(t))]
    return all_tasks

dataset/ETHPy150Open pydata/pyrallel/pyrallel/common.py TaskManager.all_tasks/original