'Run a plugin defined in the config.
plugin_name must match the plugin\'s section name in the config
cluster_tag specifies the cluster to run the plugin on'

def run_plugin(self, plugin_name, cluster_tag):

    cl = self.get_cluster(cluster_tag, load_plugins=False)
    if (not cl.is_cluster_up()):
        raise exception.ClusterNotRunning(cluster_tag)
    plugs = [self.cfg.get_plugin(plugin_name)]
    plug = deathrow._load_plugins(plugs)[0]
    cl.run_plugin(plug, name=plugin_name)
