def kill_workers(*args):
    'Syntax: [storm kill_workers]\n\n    Kill the workers running on this supervisor. This command should be run\n    on a supervisor node. If the cluster is running in secure mode, then user needs\n    to have admin rights on the node to be able to successfully kill all workers.\n    '
    exec_storm_class('org.apache.storm.command.KillWorkers', args=args, jvmtype='-client', extrajars=[USER_CONF_DIR, os.path.join(STORM_DIR, 'bin')])
Syntax: [storm kill_workers]

Kill the workers running on this supervisor. This command should be run
on a supervisor node. If the cluster is running in secure mode, then user needs
to have admin rights on the node to be able to successfully kill all workers.
def kill_workers(*args):
    'Syntax: [storm kill_workers]\n\n    Kill the workers running on this supervisor. This command should be run\n    on a supervisor node. If the cluster is running in secure mode, then user needs\n    to have admin rights on the node to be able to successfully kill all workers.\n    '
    exec_storm_class('org.apache.storm.command.KillWorkers', args=args, jvmtype='-client', extrajars=[USER_CONF_DIR, os.path.join(STORM_DIR, 'bin')])