def testBatchSizeInInputGenerator(self):
    with self.session():
      tf.random.set_seed(_TF_RANDOM_SEED)
      p = self._testParams()
      with cluster_factory.ForTestingWorker(
          mode='sync', job='trainer_client', gpus=5):
        mdl = p.Instantiate()
        mdl.FPropDefaultTheta()
        loss = mdl.loss
        self.evaluate(tf.global_variables_initializer())
        _ = self.evaluate(loss)
        self.assertEqual(mdl.input_generator.infeed_bucket_batch_limit, [40])