def _flush_ndb_puts(self, items, options):
    assert ndb is not None
    ndb.put_multi(items, config=self._create_config(options))
Flush all NDB puts to datastore.
dataset/ETHPy150Open GoogleCloudPlatform/appengine-mapreduce/python/src/mapreduce/context.py/_MutationPool._flush_ndb_puts