def AbortAdminOperation(operation_key, _status=DatastoreAdminOperation.STATUS_ABORTED, _status_info=''):
 operation = DatastoreAdminOperation.get(operation_key)
 operation.status = _status
 operation.status_info = _status_info
 operation.put(config=_CreateDatastoreConfig())
 for job in operation.active_job_ids:
  logging.info('Aborting Job %s', job)
  model.MapreduceControl.abort(job, config=_CreateDatastoreConfig())

def AbortAdminOperation ( operation_key , _status = DatastoreAdminOperation . STATUS_ABORTED , _status_info = '' ) : operation = DatastoreAdminOperation . get ( operation_key ) operation . status = _status operation . status_info = _status_info operation . put ( config = _CreateDatastoreConfig ( ) ) for job in operation . active_job_ids : logging . info ( 'Aborting Job %s' , job ) model . MapreduceControl . abort ( job , config = _CreateDatastoreConfig ( ) )
aborts active jobs .