def configure_cluster(self, cluster):
        with context.ThreadGroup() as tg:
            for instance in plugin_utils.get_instances(cluster):
                tg.spawn('fake-write-%s' % instance.id,
                         self._write_ops, instance)
dataset/ETHPy150Open openstack/sahara/sahara/plugins/fake/plugin.py/FakePluginProvider.configure_cluster/original