def METHOD_NAME(self, graph, config, updatehash=False):
    """Executes a pre-defined pipeline is distributed approaches
    based on IPython's ipyparallel processing interface
    """
    # retrieve clients again
    try:
        name = "ipyparallel"
        __import__(name)
        self.iparallel = sys.modules[name]
    except ImportError as e:
        raise ImportError(
            "ipyparallel not found. Parallel execution will be unavailable"
        ) from e
    try:
        self.taskclient = self.iparallel.Client(**self.client_args)
    except Exception as e:
        if isinstance(e, TimeoutError):
            raise Exception("No IPython clients found.") from e
        if isinstance(e, IOError):
            raise Exception("ipcluster/ipcontroller has not been started") from e
        if isinstance(e, ValueError):
            raise Exception("Ipython kernel not installed") from e
        else:
            raise e
    return super().METHOD_NAME(graph, config, updatehash=updatehash)