def _TransferItem(self, thread_pool, get_time=time.time):
    t = get_time()
    download_result = self.request_manager.GetEntities(self)
    transfer_time = get_time() - t
    mapper = self.request_manager.GetMapper()
    try:
      mapper.batch_apply(download_result.Entities())
    except MapperRetry:
      return None
    self.Process(download_result, thread_pool,
                 self.request_manager.batch_size)
    return transfer_time
dataset/ETHPy150Open IanLewis/kay/kay/management/gae_bulkloader.py/MapperItem._TransferItem/original