def new_key_pb(self):
    return entity_pb.Reference()
Re-define this to define the mapper for a one-step job.
dataset/ETHPy150Open GoogleCloudPlatform/python-compat-runtime/appengine-compat/exported_appengine_sdk/google/appengine/datastore/datastore_rpc.py/AbstractAdapter.new_key_pb--crossover with--dataset/ETHPy150Open Yelp/mrjob/mrjob/job.py/MRJob.mapper