def _run_one_off_job(self):
    'Runs the one-off MapReduce job.'
    job_class = activity_jobs_one_off.ValidateSnapshotMetadataModelsJob
    job_id = job_class.create_new()
    activity_jobs_one_off.ValidateSnapshotMetadataModelsJob.enqueue(job_id)
    self.assertEqual(self.count_jobs_in_mapreduce_taskqueue(taskqueue_services.QUEUE_NAME_ONE_OFF_JOBS), 1)
    self.process_and_flush_pending_mapreduce_tasks()
    stringified_output = activity_jobs_one_off.ValidateSnapshotMetadataModelsJob.get_output(job_id)
    eval_output = [ast.literal_eval(stringified_item) for stringified_item in stringified_output]
    return eval_output
Runs the one-off MapReduce job.
def _run_one_off_job(self):
    
    job_class = activity_jobs_one_off.ValidateSnapshotMetadataModelsJob
    job_id = job_class.create_new()
    activity_jobs_one_off.ValidateSnapshotMetadataModelsJob.enqueue(job_id)
    self.assertEqual(self.count_jobs_in_mapreduce_taskqueue(taskqueue_services.QUEUE_NAME_ONE_OFF_JOBS), 1)
    self.process_and_flush_pending_mapreduce_tasks()
    stringified_output = activity_jobs_one_off.ValidateSnapshotMetadataModelsJob.get_output(job_id)
    eval_output = [ast.literal_eval(stringified_item) for stringified_item in stringified_output]
    return eval_output