

def create_cluster(plugin_name='vanilla', hadoop_version='2.7.1'):
    cluster = mock.Mock()
    cluster.plugin_name = plugin_name
    cluster.hadoop_version = hadoop_version
    return cluster

dataset/ETHPy150Open openstack/sahara/sahara/tests/unit/service/edp/edp_test_utils.py create_cluster/original