def batch_wrapper(dataset, batch_size, distribution):
    if isinstance(distribution, tpu_strategy.TPUStrategy):
        return dataset.batch(batch_size, drop_remainder=True)
    else:
        return dataset.batch(batch_size)
def batch_wrapper(dataset, batch_size, distribution):
    if isinstance(distribution, tpu_strategy.TPUStrategy):
        return dataset.batch(batch_size, drop_remainder=True)
    else:
        return dataset.batch(batch_size)