def METHOD_NAME(self, manifest):
    schema_map = self._get_catalog_schemas(manifest)
    if len(schema_map) > 1:
        dbt.exceptions.CompilationError(
            f"Expected only one database in get_catalog, found "
            f"{list(schema_map)}"
        )
    with executor(self.config) as tpe:
        futures: List[Future[agate.Table]] = []
        for info, schemas in schema_map.items():
            for schema in schemas:
                futures.append(
                    tpe.submit_connected(
                        self,
                        schema,
                        self._get_one_catalog,
                        info,
                        [schema],
                        manifest,
                    )
                )
        catalogs, exceptions = catch_as_completed(futures)
    return catalogs, exceptions