'Takes task_instances, which should have been set to queued, and enqueues them
with the executor.
:param task_instances: TaskInstances to enqueue
:type task_instances: List[TaskInstance]
:param simple_dag_bag: Should contains all of the task_instances\' dags
:type simple_dag_bag: SimpleDagBag'

def _enqueue_task_instances_with_queued_state(self, simple_dag_bag, task_instances):

    TI = models.TaskInstance
    for task_instance in task_instances:
        command = u'    '.join(TI.generate_command(task_instance.dag_id, task_instance.task_id, task_instance.execution_date, local=True, mark_success=False, ignore_all_deps=False, ignore_depends_on_past=False, ignore_task_deps=False, ignore_ti_state=False, pool=task_instance.pool, file_path=simple_dag_bag.get_dag(task_instance.dag_id).full_filepath, pickle_id=simple_dag_bag.get_dag(task_instance.dag_id).pickle_id))
        priority = task_instance.priority_weight
        queue = task_instance.queue
        self.logger.info(u'Sending    {}    to    executor    with    priority    {}    and    queue    {}'.format(task_instance.key, priority, queue))
        copy_dag_id = task_instance.dag_id
        copy_task_id = task_instance.task_id
        copy_execution_date = task_instance.execution_date
        make_transient(task_instance)
        task_instance.dag_id = copy_dag_id
        task_instance.task_id = copy_task_id
        task_instance.execution_date = copy_execution_date
        self.executor.queue_command(task_instance, command, priority=priority, queue=queue)
