':param queue_entry: The HostQueueEntry instance calling this method.'

def run(self, queue_entry):

    if (queue_entry.atomic_group and self._atomic_and_has_started()):
        logging.error('Job.run()    called    on    running    atomic    Job    %d    with    HQE    %s.', self.id, queue_entry)
        return
    queue_entries = self._choose_group_to_run(queue_entry)
    if queue_entries:
        self._finish_run(queue_entries)
