def __flush_deletes(self):
    datastore.Delete(self.deletes.items)
    self.deletes.clear()


# This doesn't do much yet. In future it will play nicely with checkpoint/error
# handling system.
Flush all deletes to datastore.
dataset/ETHPy150Open livid/v2ex/mapreduce/context.py/MutationPool.__flush_deletes