@typecheck(ExperimentId)
    def _get_scheduler_aggregator(self, experiment_id):
        experiment_id_str = experiment_id.to_weblab_str()
        aggregator = self.aggregators.get(experiment_id_str)
        if aggregator is None:
            raise CoordExc.ExperimentNotFoundError("Could not find scheduler aggregator associated to experiment id %s." % (experiment_id_str))
        return aggregator
dataset/ETHPy150Open weblabdeusto/weblabdeusto/server/src/weblab/core/coordinator/coordinator.py/AbstractCoordinator._get_scheduler_aggregator/original