def stop_zookeeper(zk_ips, keyname):
 logging.info('Stopping ZooKeeper...')
 for ip in zk_ips:
  stop_service_cmd = (STOP_SERVICE_SCRIPT + ZK_WATCH_NAME)
  try:
   utils.ssh(ip, keyname, stop_service_cmd)
  except subprocess.CalledProcessError:
   logging.error('Unable to stop ZooKeeper on {}'.format(ip))

def stop_zookeeper ( zk_ips , keyname ) : logging . info ( 'Stopping ZooKeeper...' ) for ip in zk_ips : stop_service_cmd = ( STOP_SERVICE_SCRIPT + ZK_WATCH_NAME ) try : utils . ssh ( ip , keyname , stop_service_cmd ) except subprocess . CalledProcessError : logging . error ( 'Unable to stop ZooKeeper on {}' . format ( ip ) )
stops zookeeper .