class AggregatingJobServiceGateway implements JobServiceGateway {

    @Override
    public Observable<Job> findJob(String jobId, CallMetadata callMetadata) {
        return jobManagementServiceHelper.findJobInAllCells(jobId, callMetadata)
                .map(CellResponse::getResult)
                .map(this::addStackName);
    }

    @Inject public  AggregatingJobServiceGateway(GrpcConfiguration grpcConfiguration,
                                        TitusFederationConfiguration federationConfiguration,
                                        CellConnector connector,
                                        CellRouter router,
                                        AggregatingCellClient aggregatingClient,
                                        AggregatingJobManagementServiceHelper jobManagementServiceHelper);

}