def kill(self, topology_name, wait_time):

        cmd = ["kill", topology_name]

        if wait_time is not None:
            cmd += ["-w", wait_time]

        self._exec_storm_cmd(cmd)
Kill a topology running on the Storm cluster.
dataset/ETHPy150Open Yelp/pyleus/pyleus/cli/storm_cluster.py/StormCluster.kill