

def aggregate_model(self, mmap_mode='r'):
    ready_models = []
    for task in self.completed_tasks():
        result = task.get()
        if isinstance(result, basestring):
            result = joblib.load(result, mmap_mode=mmap_mode)
        ready_models.append(result)
    if (not ready_models):
        return None
    return combine(ready_models)

dataset/ETHPy150Open pydata/pyrallel/pyrallel/ensemble.py EnsembleGrower.aggregate_model/original