def abort_host_queue_entries(**filter_data):
 query = models.HostQueueEntry.query_objects(filter_data)
 query = query.filter(complete=False)
 models.AclGroup.check_abort_permissions(query)
 host_queue_entries = list(query.select_related())
 rpc_utils.check_abort_synchronous_jobs(host_queue_entries)
 for queue_entry in host_queue_entries:
  queue_entry.abort()

def abort_host_queue_entries ( ** filter_data ) : query = models . HostQueueEntry . query_objects ( filter_data ) query = query . filter ( complete = False ) models . AclGroup . check_abort_permissions ( query ) host_queue_entries = list ( query . select_related ( ) ) rpc_utils . check_abort_synchronous_jobs ( host_queue_entries ) for queue_entry in host_queue_entries : queue_entry . abort ( )
abort a set of host queue entries .