

def abort(self):
    for task in self.all_tasks(skip_aborted=True):
        if (not task.ready()):
            try:
                task.abort()
            except AssertionError:
                pass
    return task

dataset/ETHPy150Open pydata/pyrallel/pyrallel/common.py TaskManager.abort/VarMisuse@58/67 `self`->`task`