Synnefo » snf-ganeti » ganeti-local

  @staticmethod

  def call_jobqueue_set_drain(node_list, drain_flag):

    """Set the drain flag on the queue.

    This is a multi-node call.

    @type node_list: list

    @param node_list: the list of nodes to query

    @type drain_flag: bool

    @param drain_flag: if True, will set the drain flag, otherwise reset it.

    """

    c = Client("jobqueue_set_drain", [drain_flag])

    c.connect_list(node_list)

    c.run()

    result = c.getresult()

    return result