@fab.parallel
def start():
    """Start casssandra nodes"""

    product = dse if config['product'] == 'dse' else cstar
    cassandra_path = product.get_cassandra_path()

    # Place environment file on host:
    env = config.get('env', '')
    fab.puts('env is: {}'.format(env))

    if isinstance(env, list) or isinstance(env, tuple):
        env = "\n".join(env)
    env += "\n"
    fab.puts('env is: {}'.format(env))
    if not config['use_jna']:
        env = 'JVM_EXTRA_OPTS=-Dcassandra.boot_without_jna=true\n\n' + env
    # Turn on GC logging:
    fab.run("mkdir -p ~/fab/cassandra/logs")
    log_dir = fab.run("readlink -m {log_dir}".format(log_dir=config['log_dir']))
    try:
        ip_address = cluster_config['hosts'][fab.env.host]['internal_ip']
    except:
        ip_address = fab.env.host
    env = "JVM_OPTS=\"$JVM_OPTS -Djava.rmi.server.hostname={hostname} -Xloggc:{log_dir}/gc.log\"\n\n".format(
        hostname=ip_address, log_dir=log_dir) + env
    # Enable JMX without authentication
    env = "JVM_OPTS=\"$JVM_OPTS -Dcom.sun.management.jmxremote.port=7199 -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.authenticate=false\"\n" + env

    # Flamegraph
    if flamegraph.is_enabled(config):
        env += "JVM_OPTS=\"$JVM_OPTS -XX:+PreserveFramePointer\""

    if profiler.yourkit_is_enabled(config):
        execute(profiler.yourkit_clean)
        env += profiler.yourkit_get_jvm_opts()

    fab.puts("running with token allocation type: {}".format(config['token_allocation']))
    if config['use_vnodes'] and config['token_allocation'] in ('static-random', 'static-algorithmic'):
        env += "JVM_OPTS=\"$JVM_OPTS -Dcassandra.initial_token={}\"\n".format(
            get_static_vnode_tokens(fab.env.host,
                                    fab.env.hosts,
                                    partitioner=config['partitioner'],
                                    group=config['token_allocation']))

    env_script = "{name}.sh".format(name=uuid.uuid1())
    env_file = StringIO(env)
    fab.run('mkdir -p ~/fab/scripts')
    fab.put(env_file, '~/fab/scripts/{env_script}'.format(env_script=env_script))

    fab.puts('env is: {}'.format(env))
    if 0 > len(env_script):
        env_path = os.path.join(cassandra_path, 'conf/cassandra-env.sh')
        fab.run('echo >> ~/fab/scripts/{env_script}'.format(**locals()))
        fab.run('cat {env_path} >> ~/fab/scripts/{env_script}'.format(**locals()))
        fab.run('cp ~/fab/scripts/{env_script} {env_path}'.format(**locals()))

    product.start(config)
dataset/ETHPy150Open datastax/cstar_perf/tool/cstar_perf/tool/fab_common.py/start/swapped operands of `>`