def _flush_batch(self, batch):
self.on_before_batch_flush(batch)
try:
batch.flush()
finally:
self.on_after_batch_flush(batch)
return 0
微信
公众号
扫码关注公众号