parameters: (exec_dataset, dataset_size, phase='dataset', create_data_info_queue=False)
return_statement: return exec_dataset
docstring: Initialize and execute the dataset graph.
docstring_summary: Initialize and execute the dataset graph.
docstring_tokens: Initialize and execute the dataset graph .
function: def _exec_datagraph(exec_dataset, dataset_size, phase='dataset', create_data_info_queue=False):
      """Initialize and execute the dataset graph."""
      batch_size = exec_dataset.get_batch_size()
      input_indexs = exec_dataset.input_indexs
  
      # transform data format
      dataset_types, dataset_shapes = _get_types_and_shapes(exec_dataset)
      send_epoch_end = bool(dataset_size == -1)
      exec_dataset = exec_dataset.device_que(send_epoch_end=send_epoch_end, create_data_info_queue=create_data_info_queue)
  
      _cell_graph_executor.init_dataset(exec_dataset.queue_name,
                                        dataset_size,
                                        batch_size,
                                        dataset_types,
                                        dataset_shapes,
                                        input_indexs,
                                        phase=phase)
  
      return exec_dataset
function_tokens: def _exec_datagraph ( exec_dataset , dataset_size , phase = 'dataset' , create_data_info_queue = False ) : batch_size = exec_dataset . get_batch_size ( ) input_indexs = exec_dataset . input_indexs # transform data format dataset_types , dataset_shapes = _get_types_and_shapes ( exec_dataset ) send_epoch_end = bool ( dataset_size == - 1 ) exec_dataset = exec_dataset . device_que ( send_epoch_end = send_epoch_end , create_data_info_queue = create_data_info_queue ) _cell_graph_executor . init_dataset ( exec_dataset . queue_name , dataset_size , batch_size , dataset_types , dataset_shapes , input_indexs , phase = phase ) return exec_dataset