def _run_map_jobs(job_operation_key, backup_info_key, kinds, job_name, backup_handler, input_reader, output_writer, mapper_params, mapreduce_params, queue):
 backup_info = BackupInformation.get(backup_info_key)
 if (not backup_info):
  return []
 jobs = utils.RunMapForKinds(job_operation_key, kinds, job_name, backup_handler, input_reader, output_writer, mapper_params, mapreduce_params, queue_name=queue)
 backup_info.active_jobs = jobs
 backup_info.put(force_writes=True)
 return jobs

def _run_map_jobs ( job_operation_key , backup_info_key , kinds , job_name , backup_handler , input_reader , output_writer , mapper_params , mapreduce_params , queue ) : backup_info = BackupInformation . get ( backup_info_key ) if ( not backup_info ) : return [ ] jobs = utils . RunMapForKinds ( job_operation_key , kinds , job_name , backup_handler , input_reader , output_writer , mapper_params , mapreduce_params , queue_name = queue ) backup_info . active_jobs = jobs backup_info . put ( force_writes = True ) return jobs
creates backup/restore mr jobs for the given operation .