import os
import time


def init_cluster(scheduler_ip, n_workers, n_cores):
    os.system('./init_cluster.sh ' + scheduler_ip + ' ' + n_workers + ' ' +
        n_cores)
    time.sleep(10)


def kill_cluster(scheduler_ip):
    os.system('./kill_cluster.sh ' + scheduler_ip)
    time.sleep(10)

0ac5e4af317d5bda0d70fafc096e7c4185d88801
<mask token>

<mask token>


def init_cluster(scheduler_ip, n_workers, n_cores):
    os.system('./init_cluster.sh ' + scheduler_ip + ' ' + n_workers + ' ' +
        n_cores)
    time.sleep(10)


<mask token>

<mask token>


def init_cluster(scheduler_ip, n_workers, n_cores):
    os.system('./init_cluster.sh ' + scheduler_ip + ' ' + n_workers + ' ' +
        n_cores)
    time.sleep(10)


def kill_cluster(scheduler_ip):
    os.system('./kill_cluster.sh ' + scheduler_ip)
    time.sleep(10)

import os
import time


def init_cluster(scheduler_ip, n_workers, n_cores):
    os.system('./init_cluster.sh ' + scheduler_ip + ' ' + n_workers + ' ' +
        n_cores)
    time.sleep(10)


def kill_cluster(scheduler_ip):
    os.system('./kill_cluster.sh ' + scheduler_ip)
    time.sleep(10)
