def es_cluster()

in pytest_rally/fixtures.py [0:0]


def es_cluster(request, distribution_version, revision):
    dist = distribution_version
    rev = revision
    debug = request.config.option.debug_rally
    cluster = TestCluster(distribution_version=dist, debug=debug)
    cluster.install()
    cluster.start()
    yield cluster
    cluster.stop()