class AggregatingAutoScalingService implements AutoScalingService {

    @Override
    public Observable<GetPolicyResult> getScalingPolicy(ScalingPolicyID request, CallMetadata callMetadata) {
        // each Cell returns an Status.INTERNAL error today when the id is not found
        // TODO: make the error condition more explicit and return NOT_ERROR
        return getScalingPolicyInAllCells(request, callMetadata).map(CellResponse::getResult);
    }

    @Inject public  AggregatingAutoScalingService(CellConnector connector,
                                         GrpcConfiguration configuration,
                                         AggregatingJobManagementServiceHelper jobManagementServiceHelper,
                                         AggregatingCellClient aggregatingClient);

}